removeLimit removes the limit from prop.

retChan should be a buffered channel

the tasks should run on the source dataset shard

Channel accepts a channel to feed into the flow.

CoerceDatum changes type. If a or b is Float, changes the both to Float. Else if a or b is Decimal, changes the both to Decimal. Else if a or b is Uin

CompareInt64 returns an integer comparing the int64 x to y.

ComposeDNFCondition composes DNF items into a balance deep DNF tree.

DateFormat returns a textual representation of the time value formatted according to layout. See http://dev.mysql.com/doc/refman/5.7/en/date-and-time-

all data passing through pipe are all (size, msgpack_encoded) tuples The input and output should all be this msgpack format. Only the stdin and stdout

GetRow gets row value.

GetType gets field type of aggregate function.

HasPriKeyFlag checks if PriKeyFlag is set.

HasUnsignedFlag checks if UnsignedFlag is set.

InvOp2 returns an invalid operation error.

InvalidZero returns a boolean indicating whether the month or day is zero.

All dataset should have the same number of shards.

PropagateConstant propagate constant values of equality predicates and inequality predicates in a condition.

ReduceByKey runs the reducer registered to the reducerId, combining rows with the same key fields into one row

SetArgs sets argument by index.

SetFlag sets flag for expression.

SetMysqlDuration sets Duration value

SplitCNFItems splits CNF items. CNF means conjunctive normal form, e.g. "a and b and c".

AddCastToString adds a cast function to string type if the expr charset is not UTF8.

arrow constructs line-ending arrows according to connecting points

calcDaysInYear calculates days in one year, it works with 0 <= year <= 99.

calculateSum adds v to sum.

checkDuplicateColumnName checks if index exists duplicated columns.

convertLimitOffsetToCount changes the limit(offset, count) in prop to limit(0, offset + count).

* countLeadingZeroes returns the number of leading zeroes that can be removed from fraction. @param i start index @param word value to c

doline draws a line between to coordinates

EncodeRow encode one row of data to a blob

linestyle returns the style for lines

matchProperty calculates the cost of the physical plan if it matches the required property. It's usually called at the end of convert2PhysicalPlan. So

create a channel to aggregate values of the same key automatically close original sorted channel

parseTwoNumeric is used for pattens 0..31 0..24 0..60 and so on. It returns the parsed int, and remain data after parse.

AddParent means appending a parent for plan.

AddUint64 adds uint64 a and b if no overflow, else returns error.

AppendWarning appends a warning.

Cast casts datum to certain types.

ConvertDatumToDecimal converts datum to decimal.

DecimalDiv does division of two decimals. from1 - dividend from2 - divisor to - quotient fracIncr - increment of fraction

Decorrelate try to decorrelate the expression by schema.

DefaultTypeForValue returns the default FieldType for the value.

EncodeKey appends the encoded values to byte slice b, returns the appended slice. It guarantees the encoded value is in ascending order for comparison

EncodeUint appends the encoded value to slice b and returns the appended slice. EncodeUint guarantees that the encoded value is in ascending order for