AggFuncBenchmarkHelper benchmarks the aggregate function over data and compares to wantValue.

AggFuncTestHelper splits the data in half, runs Do over each split and compares the Value to want.

ConvertResult produces a result object from any flux.Result type.

EqualResult compares to results for equality.

EqualResultIterators compares two ResultIterators for equlity.

EqualResults compares two lists of Flux Results for equlity.

FunctionExpression will take a function expression as a string and return the *semantic.FunctionExpression.

NewFromProcedureSpec specifies a from-test procedure with source data.

NormalizeTables ensures that each table is normalized.

RunTableTests will run the common table tests over each table in the returned TableIterator.

ToTestKind represents an side-effect producing kind for testing.

AllocatingFromProcedureSpec is a procedure spec AND an execution node that allocates ByteCount bytes during execution.

DataStore will store the incoming tables from an upstream transformation or source.

FromProcedureSpec is a procedure spec AND an execution Node.

RowWiseTable is a flux Table implementation that calls f once for each row in its Do method.

Table is an implementation of execute.Table It is designed to make it easy to statically declare the data within the table.

ToProcedureSpec defines an output operation.

ToTransformation simulates an output or an identity transformation.

sql.createToSQLTransformation() and kafka.createToKafkaTransformation() converts plan.ProcedureSpec to their struct implementations ToSQLProcedureSpec and ToKafkaProcedureSpec respectively.

Some sources are located by a URL.