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 equality.

EqualResults compares two lists of Flux Results for equality.

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

NewDefaultTestFlagger gives a flagger dependency for a test harnesses to use as a baseline.

NewFromProcedureSpec specifies a from-test procedure with source data.

NewParallelFromProcedureSpec specifies a from-test procedure with source data.

NormalizeTables ensures that each table is normalized and that tables and columns are sorted in alphabetical order for consistent testing.

floatOptions is a list of comparison options for floating point values.

floatOptions is a list of comparison options for floating point values.

RunSourceHelper is a helper for testing an execute.Source.

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.

Allocator is an allocator for use in test.

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

FromProcedureSpec is a procedure spec AND an execution Node.

ParallelFromProcedureSpec is a procedure spec AND an execution Node similar to FromProcedureSpec.

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.