Check checks if values is distinct.

Column2Exprs will transfer column slice to expression slice.

GetBytes gets bytes value.

GetFloat32 gets float32 value.

GetIsOnDiskIO returns true if the dataset is persisted to disk in distributed mode.

MinNotNullDatum returns a datum represents minimum not null value.

NewIntDatum creates a new Datum from an int64 value.

ParseTimeFromNum parses a formatted int64, returns the value which type is tp.

ProcessMessage Reads and processes MessagePack encoded messages until EOF

Source produces data feeding into the flow. Function f writes to this writer. The written bytes should be MsgPack encoded []byte. Use util.EncodeRow(.

StrToFloat converts a string to a float64 at the best-effort.

ToDecimal converts to a decimal.

UseKeys use the indexes[] specified fields as key fields and the rest of fields as value fields

add adds a and b and carry, returns the sum and new carry.

buildKeyInfo will collect the information of unique keys into schema.

The select statement is not at the end of the whole statement, if the last field text was set from its offset to the end of the src string, update the

Broadcast replicates itself to all shards.

Clone copies an aggregate function totally.

collect execution stats from "gleam execute" processes

EncodeValue appends the encoded values to byte slice b, returning the appended slice. It does not guarantee the order for comparison.

FindColumn finds an Column from schema for a ast.ColumnName. It compares the db/table/column names. If there are more than one result, it will raise a

FromInt sets the decimal value from int64.

FromUint sets the decimal value from uint64.

HasNotNullFlag checks if NotNullFlag is set.

MarshalMsg implements msgp.Marshaler

MulUint64 multiplies uint64 a and b and returns uint64 if no overflow error.

hash data or by data key, return a new dataset This is divided into 2 steps: 1. Each record is sharded to a local shard 2. The destination shard will

ReadMessage reads out the []byte for one message

RoundFloat rounds float val to the nearest integer value with float64 format, like MySQL Round function. RoundFloat uses default rounding mode, see ht

Slice converts string to slice without copy. Use at your own risk.

String converts slice to string without copy. Use at your own risk.

Strings begins a flow with an []string

ToString gets the string representation of the datum.

addGbyCol adds a column to gbyCols. If a group by column has existed, it will not be added repeatedly.

See https://dev.mysql.com/doc/refman/5.7/en/two-digit-years.html

error creates a new ParseError based on err.

fixWordCntError limits word count in wordBufLen, and returns overflow or truncate error.

New creates a FileSource based on a file name. The base file name can have "*", "?" pattern denoting a list of file names.

Close closes the underlying iterator, call Next after Close will restart the iteration.

ComposeCNFCondition composes CNF items into a balance deep CNF tree, which benefits a lot for pb decoder/encoder.

DecimalSub subs one decimal from another, sets the result to 'to'.

DefaultCharsetForType returns the default charset/collation for mysql type.

EvaluateExprWithNull sets columns in schema as null and calculate the final result of the scalar function. If the Expression is a non-constant value,

Get is the same as map[k].

HasAggFlag checks if the expr contains FlagHasAggregateFunc.

Len returns the number of columns in schema.

Listen receives textual inputs via a socket. Multiple parameters are separated via tab.

MergeSchema will merge two schema into one schema.

ParseDuration parses the time form a formatted string with a fractional seconds part, returns the duration type Time value. See http://dev.mysql.com/d

ReadAll reads all the remaining records from r. Each record is a slice of fields. A successful call returns err == nil, not err == EOF. Because ReadAl

SetFloat32 sets float32 value.

StrToInt converts a string to an integer at the best-effort.

buildSemiApply builds apply plan with outerPlan and innerPlan, which apply semi-join for every row from outerPlan and the whole innerPlan.

colMatch(a,b) means that if a match b, e.g. t.a can match test.t.a bug test.t.a can't match t.a. Because column a want column from database test exact