Versions in this module Expand all Collapse all v0 v0.99.3 Jan 3, 2021 v0.99.2 Jan 3, 2021 Changes in this version + const AllocatingFromTestKind + const FromTestKind + const ToTestKind + const YieldKind + var UnlimitedAllocator = &memory.Allocator + func AggFuncBenchmarkHelper(b *testing.B, agg execute.Aggregate, data *array.Float64, want interface{}) + func AggFuncTestHelper(t *testing.T, agg execute.Aggregate, data *array.Float64, want interface{}) + func CreateAllocatingFromSource(spec plan.ProcedureSpec, id execute.DatasetID, a execute.Administration) (execute.Source, error) + func CreateFromSource(spec plan.ProcedureSpec, id execute.DatasetID, a execute.Administration) (execute.Source, error) + func CreateToTransformation(id execute.DatasetID, mode execute.AccumulationMode, spec plan.ProcedureSpec, ...) (execute.Transformation, execute.Dataset, error) + func EqualResult(w, g flux.Result) error + func EqualResultIterators(want, got flux.ResultIterator) error + func EqualResults(want, got []flux.Result) error + func FunctionExpression(t testing.TB, source string, args ...interface{}) *semantic.FunctionExpression + func IndexSelectorFuncBenchmarkHelper(b *testing.B, selector execute.IndexSelector, data flux.BufferedTable) + func IndexSelectorFuncTestHelper(t *testing.T, selector execute.IndexSelector, data flux.Table, want [][]int) + func MustCopyTable(tbl flux.Table) flux.Table + func NewDevNullStore() execute.Transformation + func NewTestExecuteDependencies() flux.Dependencies + func NewToProcedure(flux.OperationSpec, plan.Administration) (plan.ProcedureSpec, error) + func NewYieldProcedureSpec(name string) plan.PhysicalProcedureSpec + func NewYieldTransformation(d execute.Dataset, cache execute.TableBuilderCache) *yieldTransformation + func NormalizeTables(bs []*Table) + func ProcessBenchmarkHelper(b *testing.B, ...) + func ProcessTestHelper(t *testing.T, data []flux.Table, want []*Table, wantErr error, ...) + func ProcessTestHelper2(t *testing.T, data []flux.Table, want []*Table, wantErr error, ...) + func RandomDatasetID() execute.DatasetID + func RowSelectorFuncBenchmarkHelper(b *testing.B, selector execute.RowSelector, data flux.Table) + func RowSelectorFuncTestHelper(t *testing.T, selector execute.RowSelector, data flux.Table, ...) + func RunBenchmark(b *testing.B, tables []flux.BufferedTable, ...) + func RunSourceHelper(t *testing.T, want []*Table, wantErr error, ...) + func RunTableTests(t *testing.T, tt TableTest) + func TransformationPassThroughTestHelper(t *testing.T, newTr NewTransformation) + type AllocatingFromProcedureSpec struct + ByteCount int + func (AllocatingFromProcedureSpec) Cost(inStats []plan.Statistics) (cost plan.Cost, outStats plan.Statistics) + func (AllocatingFromProcedureSpec) Kind() plan.ProcedureKind + func (s *AllocatingFromProcedureSpec) AddTransformation(t execute.Transformation) + func (s *AllocatingFromProcedureSpec) Copy() plan.ProcedureSpec + func (s *AllocatingFromProcedureSpec) Run(ctx context.Context) + type ColReader struct + func (cr *ColReader) Bools(j int) *array.Boolean + func (cr *ColReader) Cols() []flux.ColMeta + func (cr *ColReader) Floats(j int) *array.Float64 + func (cr *ColReader) Ints(j int) *array.Int64 + func (cr *ColReader) Key() flux.GroupKey + func (cr *ColReader) Len() int + func (cr *ColReader) Release() + func (cr *ColReader) Retain() + func (cr *ColReader) Strings(j int) *array.Binary + func (cr *ColReader) Times(j int) *array.Int64 + func (cr *ColReader) UInts(j int) *array.Uint64 + type CreateNewTransformationWithDeps func(d execute.Dataset, deps flux.Dependencies, cache execute.TableBuilderCache, ...) (execute.Transformation, error) + type DataStore struct + func NewDataStore() *DataStore + func (d *DataStore) DiscardTable(key flux.GroupKey) + func (d *DataStore) Err() error + func (d *DataStore) ExpireTable(key flux.GroupKey) + func (d *DataStore) Finish(id execute.DatasetID, err error) + func (d *DataStore) ForEach(f func(key flux.GroupKey)) + func (d *DataStore) ForEachWithContext(f func(flux.GroupKey, execute.Trigger, execute.TableContext)) + func (d *DataStore) Process(id execute.DatasetID, tbl flux.Table) error + func (d *DataStore) RetractTable(id execute.DatasetID, key flux.GroupKey) error + func (d *DataStore) SetTriggerSpec(t plan.TriggerSpec) + func (d *DataStore) Table(key flux.GroupKey) (flux.Table, error) + func (d *DataStore) UpdateProcessingTime(id execute.DatasetID, t execute.Time) error + func (d *DataStore) UpdateWatermark(id execute.DatasetID, t execute.Time) error + type Dataset struct + Finished bool + FinishedErr error + ID execute.DatasetID + ProcessingTimeUpdates []execute.Time + Retractions []flux.GroupKey + WatermarkUpdates []execute.Time + func NewDataset(id execute.DatasetID) *Dataset + func (d *Dataset) AddTransformation(t execute.Transformation) + func (d *Dataset) Finish(err error) + func (d *Dataset) RetractTable(key flux.GroupKey) error + func (d *Dataset) SetTriggerSpec(t plan.TriggerSpec) + func (d *Dataset) UpdateProcessingTime(t execute.Time) error + func (d *Dataset) UpdateWatermark(mark execute.Time) error + type FromProcedureSpec struct + func NewFromProcedureSpec(data []*Table) *FromProcedureSpec + func (src *FromProcedureSpec) AddTransformation(t execute.Transformation) + func (src *FromProcedureSpec) Copy() plan.ProcedureSpec + func (src *FromProcedureSpec) Cost(inStats []plan.Statistics) (plan.Cost, plan.Statistics) + func (src *FromProcedureSpec) Kind() plan.ProcedureKind + func (src *FromProcedureSpec) Run(ctx context.Context) + type NewTransformation func(execute.Dataset, execute.TableBuilderCache) execute.Transformation + type Result struct + Err error + Nm string + Tbls []*Table + func ConvertResult(result flux.Result) *Result + func NewResult(tables []*Table) *Result + func (r *Result) Name() string + func (r *Result) Normalize() + func (r *Result) Tables() flux.TableIterator + type RowWiseTable struct + func (t *RowWiseTable) Do(f func(flux.ColReader) error) error + type SortedTables []*Table + func (b SortedTables) Len() int + func (b SortedTables) Less(i int, j int) bool + func (b SortedTables) Swap(i int, j int) + type SourceUrlValidationTestCases []struct + func (testCases *SourceUrlValidationTestCases) Run(t *testing.T, fn execute.CreateSource) + type Table struct + Alloc *memory.Allocator + ColMeta []flux.ColMeta + Data [][]interface{} + Err error + GroupKey flux.GroupKey + IsDone bool + KeyCols []string + KeyValues []interface{} + func ConvertTable(tbl flux.Table) (*Table, error) + func TablesFromCache(c execute.DataCache) (tables []*Table, err error) + func (t *Table) Cols() []flux.ColMeta + func (t *Table) Do(f func(flux.ColReader) error) error + func (t *Table) Done() + func (t *Table) Empty() bool + func (t *Table) Key() flux.GroupKey + func (t *Table) Normalize() + type TableIterator struct + Err error + Tables []*Table + func (ti *TableIterator) Do(f func(flux.Table) error) error + type TableTest struct + IsDone func(flux.Table) bool + NewFn func(ctx context.Context, alloc *memory.Allocator) flux.TableIterator + type TfUrlValidationTest struct + Cases []TfUrlValidationTestCase + CreateFn CreateNewTransformationWithDeps + func (test *TfUrlValidationTest) Run(t *testing.T) + type TfUrlValidationTestCase struct + Name string + Spec plan.ProcedureSpec + Validator url.Validator + WantErr string + type ToProcedureSpec struct + func (s *ToProcedureSpec) Copy() plan.ProcedureSpec + func (s *ToProcedureSpec) Cost(inStats []plan.Statistics) (plan.Cost, plan.Statistics) + func (s *ToProcedureSpec) Kind() plan.ProcedureKind + type ToTransformation struct + func (t *ToTransformation) Finish(id execute.DatasetID, err error) + func (t *ToTransformation) Process(id execute.DatasetID, tbl flux.Table) error + func (t *ToTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error + func (t *ToTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error + func (t *ToTransformation) UpdateWatermark(id execute.DatasetID, pt execute.Time) error + type YieldProcedureSpec struct + func (YieldProcedureSpec) Kind() plan.ProcedureKind + func (y YieldProcedureSpec) Copy() plan.ProcedureSpec + func (y YieldProcedureSpec) YieldName() string