AdjustYear is used for adjusting year and checking its validation.

BuiltinValuesFactory generates values builtin function.

CalculateDefaultValue gets the default value when the aggregate function's input is null. The input stands for the schema of Aggregation's child. If t

CastFuncFactory produces builtin function according to field types. See https://dev.mysql.com/doc/refman/5.7/en/cast-functions.html

CheckNotNull checks if nil value set to a column with NotNull flag is set.

Close implements io.Closer, and closes the current logfile.

CoGroupPartitionedSorted joins 2 datasets that are sharded by the same key and already locally sorted within each shard.

ColDescFieldNames returns the fields name in result set for desc and show columns.

Compare returns an integer comparing the Duration instant t to o. If d is after o, return 1, equal o, return 0, before o, return -1.

CompareUint64 returns an integer comparing the uint64 x to y.

Compile is safe for concurrent use by multiple goroutines.

ComputeDiv computes the result of a/b.

ComputeIntDiv computes the result of a / b, both a and b are integer.

ComputeMinus computes the result of a-b.

ComputeMod computes the result of a mod b.

ComputeMul computes the result of a*b.

ConvertToDuration converts mysql datetime, timestamp and date to mysql time type. e.g, 2012-12-12T10:10:10 -> 10:10:10 2012-12-12 -> 0

ConvertToTime converts duration to Time. Tp is TypeDatetime, TypeTimestamp and TypeDate.

Copy implements the PhysicalPlan Copy interface.

setup asynchronously to merge multiple channels into one channel

CreateSession creates a new session environment.

DateDiff calculates number of days between two days.

DecimalAdd adds two decimals, sets the result to 'to'.

* DecimalMod does modulus of two decimals. from1 - dividend from2 - divisor to - modulus RETURN VALUE E_DEC_OK/E_DE

DecimalPeak returns the length of the encoded decimal.

Decode decodes values from a byte slice generated with EncodeKey or EncodeValue before. size is the size of decoded datum slice.

DecodeBytes decodes bytes which is encoded by EncodeBytes before, returns the leftover bytes and decoded value if no error.

DecodeCompactBytes decodes bytes which is encoded by EncodeCompactBytes before.

DecodeDecimal decodes bytes to decimal.

DecodeFloat decodes a float from a byte slice generated with EncodeFloat before.

DecodeMsg implements msgp.Decodable We treat empty fields as if we read a Nil from the wire.

DecodeOne decodes on datum from a byte slice generated with EncodeKey or EncodeValue.

DecodeUintDesc decodes value encoded by EncodeInt before. It returns the leftover un-decoded slice, decoded value if no error.

DecodeUvarint decodes value encoded by EncodeUvarint before. It returns the leftover un-decoded slice, decoded value if no error.

the distance is a relative value, similar to network lantency

DivInt64 divides int64 a with b, returns int64 if no overflow error. It just checks overflow, if b is zero, a "divide by zero" panic throws.

DivIntWithUint divides int64 a with uint64 b, returns uint64 if no overflow error. It just checks overflow, if b is zero, a "divide by zero" panic thr

DivUintWithInt divides uint64 a with int64 b, returns uint64 if no overflow error. It just checks overflow, if b is zero, a "divide by zero" panic thr

DoLocalLimit streamingly get the n items starting from offset

DoLocalTop streamingly compare and get the top n items

DoSelect projects the fields

EncodeCompactBytes joins bytes with its length into a byte slice. It is more efficient in both space and time compare to EncodeBytes. Note that the en

EncodeComparableUvarint encodes uint64 into mem-comparable bytes.

EncodeDecimal encodes a decimal d into a byte slice which can be sorted lexicographically later.

EncodeFloat encodes a float v into a byte slice which can be sorted lexicographically later. EncodeFloat guarantees that the encoded value is in ascen

EncodeMsg implements msgp.Encodable

EncodeUintDesc appends the encoded value to slice b and returns the appended slice. EncodeUintDesc guarantees that the encoded value is in descending

EncodeUvarint appends the encoded value to slice b and returns the appended slice. Note that the encoded result is not memcomparable.

Equal checks if err is equal to e.

Equal checks whether two aggregation functions are equal.

EqualClass returns true if err is *Error with the same class.

ExecuteTaskGroup wait for inputs and execute the task group remotely. If cancelled, the output will be cleaned up.

ExtractTimeNum extracts time value number from time unit and format.

ExtractTimeValue extracts time value from time unit and format.

FindCol finds column in cols by name.

FoundRows gets found rows.

Fprintf reads MessagePack encoded messages from reader, and formats according to a format specifier and writes to writer.

FromBin Restores decimal from its binary fixed-length representation.

GetCharsetInfo returns charset and collation for cs as name.

GetColDefaultValue gets default value of the column.

GetGlobalSystemVar gets a global system variable.