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 DefaultStartColLabel + const DefaultStopColLabel + const DefaultTimeColLabel + const DefaultValueColLabel + const MaxTime + const MinTime + const OperatorProfilerContextKey + var AllProfilers = make(map[string]CreateProfilerFunc) + var AllTime = Bounds + var DefaultAggregateConfig = AggregateConfig + var DefaultSelectorConfig = SelectorConfig + func AddNewTableCols(t flux.Table, builder TableBuilder, colMap []int) ([]int, error) + func AddTableCols(t flux.Table, builder TableBuilder) error + func AddTableKeyCols(key flux.GroupKey, builder TableBuilder) error + func AppendCol(bj, cj int, cr flux.ColReader, builder TableBuilder) error + func AppendCols(cr flux.ColReader, builder TableBuilder) error + func AppendKeyValues(key flux.GroupKey, builder TableBuilder) error + func AppendKeyValuesN(key flux.GroupKey, builder TableBuilder, n int) error + func AppendMappedCols(cr flux.ColReader, builder TableBuilder, colMap []int) error + func AppendMappedRecordExplicit(i int, cr flux.ColReader, builder TableBuilder, colMap []int) error + func AppendMappedRecordWithNulls(i int, cr flux.ColReader, builder TableBuilder, colMap []int) error + func AppendMappedTable(t flux.Table, builder TableBuilder, colMap []int) error + func AppendRecord(i int, cr flux.ColReader, builder TableBuilder) error + func AppendTable(t flux.Table, builder TableBuilder) error + func BuilderColsMatchReader(builder TableBuilder, cr flux.ColReader) bool + func CheckColType(col flux.ColMeta, typ flux.ColType) + func ColIdx(label string, cols []flux.ColMeta) int + func ColMap(colMap []int, builder TableBuilder, cols []flux.ColMeta) []int + func ContainsStr(strs []string, str string) bool + func ConvertFromKind(k semantic.Nature) flux.ColType + func ConvertToKind(t flux.ColType) semantic.Nature + func CopyTable(t flux.Table) (flux.BufferedTable, error) + func FormatResult(w io.Writer, res flux.Result) error + func GroupKeyForRowOn(i int, cr flux.ColReader, on map[string]bool) flux.GroupKey + func HasCol(label string, cols []flux.ColMeta) bool + func HaveExecutionDependencies(ctx context.Context) bool + func NewAggregateTransformation(d Dataset, c TableBuilderCache, agg Aggregate, config AggregateConfig) *aggregateTransformation + func NewDataset(id DatasetID, accMode AccumulationMode, cache DataCache) *dataset + func NewEmptyTable(key flux.GroupKey, cols []flux.ColMeta) flux.Table + func NewGroupKey(cols []flux.ColMeta, values []values.Value) flux.GroupKey + func NewIndexSelectorTransformation(d Dataset, c TableBuilderCache, selector IndexSelector, config SelectorConfig) *indexSelectorTransformation + func NewRowSelectorTransformation(d Dataset, c TableBuilderCache, selector RowSelector, config SelectorConfig) *rowSelectorTransformation + func NewTableBuilderCache(a *memory.Allocator) *tableBuilderCache + func PanicUnknownType(typ flux.ColType) + func RegisterProfilerFactories(cpfs ...CreateProfilerFunc) + func RegisterSource(k plan.ProcedureKind, c CreateSource) + func RegisterTransformation(k plan.ProcedureKind, c CreateTransformation) + func ReplaceTransformation(k plan.ProcedureKind, c CreateTransformation) + func StartSpanFromContext(ctx context.Context, operationName string, label string, ...) (context.Context, opentracing.Span) + func TablesEqual(left, right flux.Table, alloc *memory.Allocator) (bool, error) + func ValueForRow(cr flux.ColReader, i, j int) values.Value + type AccumulationMode int + const AccumulatingMode + const DiscardingMode + type Administration interface + Allocator func() *memory.Allocator + Context func() context.Context + Parents func() []DatasetID + ResolveTime func(qt flux.Time) Time + StreamContext func() StreamContext + type Aggregate interface + NewBoolAgg func() DoBoolAgg + NewFloatAgg func() DoFloatAgg + NewIntAgg func() DoIntAgg + NewStringAgg func() DoStringAgg + NewUIntAgg func() DoUIntAgg + type AggregateConfig struct + Columns []string + func (c *AggregateConfig) ReadArgs(args flux.Arguments) error + func (c AggregateConfig) Copy() AggregateConfig + type Allocator struct + func (a *Allocator) AppendBools(slice []bool, vs ...bool) []bool + func (a *Allocator) AppendFloats(slice []float64, vs ...float64) []float64 + func (a *Allocator) AppendInts(slice []int64, vs ...int64) []int64 + func (a *Allocator) AppendStrings(slice []string, vs ...string) []string + func (a *Allocator) AppendTimes(slice []Time, vs ...Time) []Time + func (a *Allocator) AppendUInts(slice []uint64, vs ...uint64) []uint64 + func (a *Allocator) Bools(l, c int) []bool + func (a *Allocator) Floats(l, c int) []float64 + func (a *Allocator) Free(n, size int) + func (a *Allocator) GrowBools(slice []bool, n int) []bool + func (a *Allocator) GrowFloats(slice []float64, n int) []float64 + func (a *Allocator) GrowInts(slice []int64, n int) []int64 + func (a *Allocator) GrowStrings(slice []string, n int) []string + func (a *Allocator) GrowTimes(slice []Time, n int) []Time + func (a *Allocator) GrowUInts(slice []uint64, n int) []uint64 + func (a *Allocator) Ints(l, c int) []int64 + func (a *Allocator) Strings(l, c int) []string + func (a *Allocator) Times(l, c int) []Time + func (a *Allocator) UInts(l, c int) []uint64 + type BoolValueFunc interface + ValueBool func() bool + type Bounds struct + Start Time + Stop Time + func (b *Bounds) Intersect(o Bounds) Bounds + func (b Bounds) Contains(t Time) bool + func (b Bounds) Duration() Duration + func (b Bounds) Equal(o Bounds) bool + func (b Bounds) IsEmpty() bool + func (b Bounds) Overlaps(o Bounds) bool + func (b Bounds) Shift(d Duration) Bounds + func (b Bounds) String() string + type ColListTable struct + func (t *ColListTable) Bools(j int) *array.Boolean + func (t *ColListTable) Cols() []flux.ColMeta + func (t *ColListTable) Do(f func(flux.ColReader) error) error + func (t *ColListTable) Done() + func (t *ColListTable) Empty() bool + func (t *ColListTable) Floats(j int) *array.Float64 + func (t *ColListTable) GetRow(row int) values.Object + func (t *ColListTable) Ints(j int) *array.Int64 + func (t *ColListTable) Key() flux.GroupKey + func (t *ColListTable) Len() int + func (t *ColListTable) NRows() int + func (t *ColListTable) RefCount(n int) + func (t *ColListTable) Release() + func (t *ColListTable) Retain() + func (t *ColListTable) Strings(j int) *array.Binary + func (t *ColListTable) Times(j int) *array.Int64 + func (t *ColListTable) UInts(j int) *array.Uint64 + type ColListTableBuilder struct + func NewColListTableBuilder(key flux.GroupKey, a *memory.Allocator) *ColListTableBuilder + func (b *ColListTableBuilder) AddCol(c flux.ColMeta) (int, error) + func (b *ColListTableBuilder) AppendBool(j int, value bool) error + func (b *ColListTableBuilder) AppendBools(j int, vs *array.Boolean) error + func (b *ColListTableBuilder) AppendFloat(j int, value float64) error + func (b *ColListTableBuilder) AppendFloats(j int, vs *array.Float64) error + func (b *ColListTableBuilder) AppendInt(j int, value int64) error + func (b *ColListTableBuilder) AppendInts(j int, vs *array.Int64) error + func (b *ColListTableBuilder) AppendNil(j int) error + func (b *ColListTableBuilder) AppendString(j int, value string) error + func (b *ColListTableBuilder) AppendStrings(j int, vs *array.Binary) error + func (b *ColListTableBuilder) AppendTime(j int, value Time) error + func (b *ColListTableBuilder) AppendTimes(j int, vs *array.Int64) error + func (b *ColListTableBuilder) AppendUInt(j int, value uint64) error + func (b *ColListTableBuilder) AppendUInts(j int, vs *array.Uint64) error + func (b *ColListTableBuilder) AppendValue(j int, v values.Value) error + func (b *ColListTableBuilder) Bools(j int) []bool + func (b *ColListTableBuilder) ClearData() + func (b *ColListTableBuilder) Cols() []flux.ColMeta + func (b *ColListTableBuilder) Floats(j int) []float64 + func (b *ColListTableBuilder) GetRow(row int) values.Object + func (b *ColListTableBuilder) GrowBools(j, n int) error + func (b *ColListTableBuilder) GrowFloats(j, n int) error + func (b *ColListTableBuilder) GrowInts(j, n int) error + func (b *ColListTableBuilder) GrowStrings(j, n int) error + func (b *ColListTableBuilder) GrowTimes(j, n int) error + func (b *ColListTableBuilder) GrowUInts(j, n int) error + func (b *ColListTableBuilder) Ints(j int) []int64 + func (b *ColListTableBuilder) Key() flux.GroupKey + func (b *ColListTableBuilder) Len() int + func (b *ColListTableBuilder) LevelColumns() error + func (b *ColListTableBuilder) NCols() int + func (b *ColListTableBuilder) NRows() int + func (b *ColListTableBuilder) Release() + func (b *ColListTableBuilder) SetBool(i int, j int, value bool) error + func (b *ColListTableBuilder) SetFloat(i int, j int, value float64) error + func (b *ColListTableBuilder) SetInt(i int, j int, value int64) error + func (b *ColListTableBuilder) SetNil(i, j int) error + func (b *ColListTableBuilder) SetString(i int, j int, value string) error + func (b *ColListTableBuilder) SetTime(i int, j int, value Time) error + func (b *ColListTableBuilder) SetUInt(i int, j int, value uint64) error + func (b *ColListTableBuilder) SetValue(i, j int, v values.Value) error + func (b *ColListTableBuilder) SliceColumns(start, stop int) error + func (b *ColListTableBuilder) Sort(cols []string, desc bool) + func (b *ColListTableBuilder) Strings(j int) []string + func (b *ColListTableBuilder) Table() (flux.Table, error) + func (b *ColListTableBuilder) Times(j int) []values.Time + func (b *ColListTableBuilder) UInts(j int) []uint64 + type CreateProfilerFunc func() Profiler + type CreateSource func(spec plan.ProcedureSpec, id DatasetID, ctx Administration) (Source, error) + type CreateTransformation func(id DatasetID, mode AccumulationMode, spec plan.ProcedureSpec, a Administration) (Transformation, Dataset, error) + type DataCache interface + DiscardTable func(flux.GroupKey) + ExpireTable func(flux.GroupKey) + ForEach func(func(flux.GroupKey)) + ForEachWithContext func(func(flux.GroupKey, Trigger, TableContext)) + SetTriggerSpec func(t plan.TriggerSpec) + Table func(flux.GroupKey) (flux.Table, error) + type Dataset interface + Finish func(error) + RetractTable func(key flux.GroupKey) error + SetTriggerSpec func(t plan.TriggerSpec) + UpdateProcessingTime func(t Time) error + UpdateWatermark func(mark Time) error + func NewAggregateTransformationAndDataset(id DatasetID, mode AccumulationMode, agg Aggregate, config AggregateConfig, ...) (*aggregateTransformation, Dataset) + func NewIndexSelectorTransformationAndDataset(id DatasetID, mode AccumulationMode, selector IndexSelector, ...) (*indexSelectorTransformation, Dataset) + func NewRowSelectorTransformationAndDataset(id DatasetID, mode AccumulationMode, selector RowSelector, ...) (*rowSelectorTransformation, Dataset) + type DatasetID uuid.UUID + var ZeroDatasetID DatasetID + func DatasetIDFromNodeID(id plan.NodeID) DatasetID + func (id DatasetID) IsZero() bool + func (id DatasetID) String() string + type Dispatcher interface + Schedule func(fn ScheduleFunc) + type DoBoolAgg interface + DoBool func(*array.Boolean) + type DoBoolIndexSelector interface + DoBool func(*array.Boolean) []int + type DoBoolRowSelector interface + DoBool func(vs *array.Boolean, cr flux.ColReader) + type DoFloatAgg interface + DoFloat func(*array.Float64) + type DoFloatIndexSelector interface + DoFloat func(*array.Float64) []int + type DoFloatRowSelector interface + DoFloat func(vs *array.Float64, cr flux.ColReader) + type DoIntAgg interface + DoInt func(*array.Int64) + type DoIntIndexSelector interface + DoInt func(*array.Int64) []int + type DoIntRowSelector interface + DoInt func(vs *array.Int64, cr flux.ColReader) + type DoStringAgg interface + DoString func(*array.Binary) + type DoStringIndexSelector interface + DoString func(*array.Binary) []int + type DoStringRowSelector interface + DoString func(vs *array.Binary, cr flux.ColReader) + type DoTimeIndexSelector interface + DoTime func(*array.Int64) []int + type DoTimeRowSelector interface + DoTime func(vs *array.Int64, cr flux.ColReader) + type DoUIntAgg interface + DoUInt func(*array.Uint64) + type DoUIntIndexSelector interface + DoUInt func(*array.Uint64) []int + type DoUIntRowSelector interface + DoUInt func(vs *array.Uint64, cr flux.ColReader) + type Duration = values.Duration + type ExecutionDependencies struct + Allocator *memory.Allocator + ExecutionOptions *ExecutionOptions + Logger *zap.Logger + Metadata metadata.Metadata + Now *time.Time + func DefaultExecutionDependencies() ExecutionDependencies + func GetExecutionDependencies(ctx context.Context) ExecutionDependencies + func NewExecutionDependencies(allocator *memory.Allocator, now *time.Time, logger *zap.Logger) ExecutionDependencies + func (d ExecutionDependencies) Inject(ctx context.Context) context.Context + type ExecutionNode struct + func (n *ExecutionNode) Label() string + func (n *ExecutionNode) SetLabel(label string) + type ExecutionOptions struct + OperatorProfiler *OperatorProfiler + Profilers []Profiler + type Executor interface + Execute func(ctx context.Context, p *plan.Spec, a *memory.Allocator) (map[string]flux.Result, <-chan metadata.Metadata, error) + func NewExecutor(logger *zap.Logger) Executor + type FinishMsg interface + Error func() error + type FloatValueFunc interface + ValueFloat func() float64 + type FormatOptions struct + NullRepresentation string + RepeatHeaderCount int + func DefaultFormatOptions() *FormatOptions + type Formatter struct + func NewFormatter(tbl flux.Table, opts *FormatOptions) *Formatter + func (f *Formatter) WriteTo(out io.Writer) (int64, error) + type GroupKeyBuilder struct + func NewGroupKeyBuilder(key flux.GroupKey) *GroupKeyBuilder + func (gkb *GroupKeyBuilder) AddKeyValue(key string, value values.Value) *GroupKeyBuilder + func (gkb *GroupKeyBuilder) Build() (flux.GroupKey, error) + func (gkb *GroupKeyBuilder) Grow(n int) + func (gkb *GroupKeyBuilder) Len() int + func (gkb *GroupKeyBuilder) SetKeyValue(key string, value values.Value) *GroupKeyBuilder + type GroupLookup struct + func NewGroupLookup() *GroupLookup + func (l *GroupLookup) Clear() + func (l *GroupLookup) Delete(key flux.GroupKey) (v interface{}, found bool) + func (l *GroupLookup) Lookup(key flux.GroupKey) (interface{}, bool) + func (l *GroupLookup) LookupOrCreate(key flux.GroupKey, fn func() interface{}) interface{} + func (l *GroupLookup) Range(f func(key flux.GroupKey, value interface{})) + func (l *GroupLookup) Set(key flux.GroupKey, value interface{}) + type IndexSelector interface + NewBoolSelector func() DoBoolIndexSelector + NewFloatSelector func() DoFloatIndexSelector + NewIntSelector func() DoIntIndexSelector + NewStringSelector func() DoStringIndexSelector + NewTimeSelector func() DoTimeIndexSelector + NewUIntSelector func() DoUIntIndexSelector + type IntValueFunc interface + ValueInt func() int64 + type Message interface + SrcDatasetID func() DatasetID + Type func() MessageType + type MessageQueue interface + Pop func() Message + Push func(Message) + type MessageType int + const FinishType + const ProcessType + const RetractTableType + const UpdateProcessingTimeType + const UpdateWatermarkType + type MetadataNode interface + Metadata func() metadata.Metadata + type Node interface + AddTransformation func(t Transformation) + type OperatorProfiler struct + func (o *OperatorProfiler) GetResult(q flux.Query, alloc *memory.Allocator) (flux.Table, error) + func (o *OperatorProfiler) GetSortedResult(q flux.Query, alloc *memory.Allocator, desc bool, sortKeys ...string) (flux.Table, error) + func (o *OperatorProfiler) Name() string + type OperatorProfilingResult struct + Label string + Start time.Time + Stop time.Time + Type string + type OperatorProfilingSpan struct + Result OperatorProfilingResult + func (t *OperatorProfilingSpan) Finish() + func (t *OperatorProfilingSpan) FinishWithOptions(opts opentracing.FinishOptions) + type PassthroughDataset struct + func NewPassthroughDataset(id DatasetID) *PassthroughDataset + func (d *PassthroughDataset) AddTransformation(t Transformation) + func (d *PassthroughDataset) Finish(err error) + func (d *PassthroughDataset) Process(tbl flux.Table) error + func (d *PassthroughDataset) RetractTable(key flux.GroupKey) error + func (d *PassthroughDataset) SetTriggerSpec(t plan.TriggerSpec) + func (d *PassthroughDataset) UpdateProcessingTime(t Time) error + func (d *PassthroughDataset) UpdateWatermark(mark Time) error + type ProcessMsg interface + Table func() flux.Table + type Profiler interface + GetResult func(q flux.Query, alloc *memory.Allocator) (flux.Table, error) + GetSortedResult func(q flux.Query, alloc *memory.Allocator, desc bool, sortKeys ...string) (flux.Table, error) + Name func() string + type QueryProfiler struct + func (s *QueryProfiler) GetResult(q flux.Query, alloc *memory.Allocator) (flux.Table, error) + func (s *QueryProfiler) GetSortedResult(q flux.Query, alloc *memory.Allocator, desc bool, sortKeys ...string) (flux.Table, error) + func (s *QueryProfiler) Name() string + type RandomAccessGroupLookup struct + func NewRandomAccessGroupLookup() *RandomAccessGroupLookup + func (l *RandomAccessGroupLookup) Clear() + func (l *RandomAccessGroupLookup) Delete(key flux.GroupKey) (v interface{}, found bool) + func (l *RandomAccessGroupLookup) Lookup(key flux.GroupKey) (interface{}, bool) + func (l *RandomAccessGroupLookup) LookupOrCreate(key flux.GroupKey, fn func() interface{}) interface{} + func (l *RandomAccessGroupLookup) Range(f func(key flux.GroupKey, value interface{})) + func (l *RandomAccessGroupLookup) Set(key flux.GroupKey, value interface{}) + type RetractTableMsg interface + Key func() flux.GroupKey + type Row struct + Values []interface{} + func ReadRow(i int, cr flux.ColReader) (row Row) + type RowMapFn struct + func NewRowMapFn(fn *semantic.FunctionExpression, scope compiler.Scope) *RowMapFn + func (f *RowMapFn) Prepare(cols []flux.ColMeta) (*RowMapPreparedFn, error) + type RowMapPreparedFn struct + func (f *RowMapPreparedFn) Eval(ctx context.Context, row int, cr flux.ColReader) (values.Object, error) + func (f *RowMapPreparedFn) Type() semantic.MonoType + type RowPredicateFn struct + func NewRowPredicateFn(fn *semantic.FunctionExpression, scope compiler.Scope) *RowPredicateFn + func (f *RowPredicateFn) Prepare(cols []flux.ColMeta) (*RowPredicatePreparedFn, error) + type RowPredicatePreparedFn struct + func (f *RowPredicatePreparedFn) Eval(ctx context.Context, record values.Object) (bool, error) + func (f *RowPredicatePreparedFn) EvalRow(ctx context.Context, row int, cr flux.ColReader) (bool, error) + func (f *RowPredicatePreparedFn) InferredInputType() semantic.MonoType + func (f *RowPredicatePreparedFn) InputType() semantic.MonoType + type RowReader interface + ColumnNames func() []string + ColumnTypes func() []flux.ColType + GetNextRow func() ([]values.Value, error) + Next func() bool + SetColumns func([]interface{}) + type RowReduceFn struct + func NewRowReduceFn(fn *semantic.FunctionExpression, scope compiler.Scope) *RowReduceFn + func (f *RowReduceFn) Prepare(cols []flux.ColMeta, reducerType map[string]semantic.MonoType) (*RowReducePreparedFn, error) + type RowReducePreparedFn struct + func (f *RowReducePreparedFn) Eval(ctx context.Context, row int, cr flux.ColReader, ...) (values.Object, error) + func (f *RowReducePreparedFn) Type() semantic.MonoType + type RowSelector interface + NewBoolSelector func() DoBoolRowSelector + NewFloatSelector func() DoFloatRowSelector + NewIntSelector func() DoIntRowSelector + NewStringSelector func() DoStringRowSelector + NewTimeSelector func() DoTimeRowSelector + NewUIntSelector func() DoUIntRowSelector + type Rower interface + Rows func() []Row + type ScheduleFunc func(ctx context.Context, throughput int) + type SelectorConfig struct + Column string + func (c *SelectorConfig) ReadArgs(args flux.Arguments) error + type Source interface + Label func() string + Run func(ctx context.Context) + SetLabel func(label string) + func CreateSourceFromDecoder(decoder SourceDecoder, dsid DatasetID, a Administration) (Source, error) + func CreateSourceFromIterator(iterator SourceIterator, dsid DatasetID) (Source, error) + type SourceDecoder interface + Close func() error + Connect func(ctx context.Context) error + Decode func(ctx context.Context) (flux.Table, error) + Fetch func(ctx context.Context) (bool, error) + type SourceIterator interface + Do func(ctx context.Context, f func(flux.Table) error) error + type StreamContext interface + Bounds func() *Bounds + type StringValueFunc interface + ValueString func() string + type TableBuilder interface + AddCol func(flux.ColMeta) (int, error) + AppendBool func(j int, value bool) error + AppendBools func(j int, vs *array.Boolean) error + AppendFloat func(j int, value float64) error + AppendFloats func(j int, vs *array.Float64) error + AppendInt func(j int, value int64) error + AppendInts func(j int, vs *array.Int64) error + AppendNil func(j int) error + AppendString func(j int, value string) error + AppendStrings func(j int, vs *array.Binary) error + AppendTime func(j int, value Time) error + AppendTimes func(j int, vs *array.Int64) error + AppendUInt func(j int, value uint64) error + AppendUInts func(j int, vs *array.Uint64) error + AppendValue func(j int, value values.Value) error + ClearData func() + Cols func() []flux.ColMeta + GrowBools func(j, n int) error + GrowFloats func(j, n int) error + GrowInts func(j, n int) error + GrowStrings func(j, n int) error + GrowTimes func(j, n int) error + GrowUInts func(j, n int) error + Key func() flux.GroupKey + LevelColumns func() error + NCols func() int + NRows func() int + Release func() + SetNil func(i, j int) error + SetValue func(i, j int, value values.Value) error + Sort func(cols []string, desc bool) + Table func() (flux.Table, error) + type TableBuilderCache interface + ForEachBuilder func(f func(flux.GroupKey, TableBuilder)) + TableBuilder func(key flux.GroupKey) (TableBuilder, bool) + type TableContext struct + Count int + Key flux.GroupKey + type TablePredicateFn struct + func NewTablePredicateFn(fn *semantic.FunctionExpression, scope compiler.Scope) *TablePredicateFn + func (f *TablePredicateFn) Prepare(tbl flux.Table) (*TablePredicatePreparedFn, error) + type TablePredicatePreparedFn struct + func (f *TablePredicatePreparedFn) Eval(ctx context.Context, tbl flux.Table) (bool, error) + type Time = values.Time + func Now() Time + type Transformation interface + Finish func(id DatasetID, err error) + Label func() string + Process func(id DatasetID, tbl flux.Table) error + RetractTable func(id DatasetID, key flux.GroupKey) error + SetLabel func(label string) + UpdateProcessingTime func(id DatasetID, t Time) error + UpdateWatermark func(id DatasetID, t Time) error + type TransformationSet []Transformation + func (ts TransformationSet) Finish(id DatasetID, err error) + func (ts TransformationSet) Process(id DatasetID, tbl flux.Table) error + func (ts TransformationSet) RetractTable(id DatasetID, key flux.GroupKey) error + func (ts TransformationSet) UpdateProcessingTime(id DatasetID, time Time) error + func (ts TransformationSet) UpdateWatermark(id DatasetID, time Time) error + type Transport interface + Finished func() <-chan struct{} + type Trigger interface + Finished func() bool + Reset func() + Triggered func(TriggerContext) bool + func NewTriggerFromSpec(spec plan.TriggerSpec) Trigger + type TriggerContext struct + CurrentProcessingTime Time + Table TableContext + Watermark Time + type UIntValueFunc interface + ValueUInt func() uint64 + type UpdateProcessingTimeMsg interface + ProcessingTime func() Time + type UpdateWatermarkMsg interface + WatermarkTime func() Time + type ValueFunc interface + IsNull func() bool + Type func() flux.ColType + type Window struct + Every Duration + Offset Duration + Period Duration + func NewWindow(every, period, offset Duration) (Window, error) + func (w Window) GetEarliestBounds(t Time) Bounds + func (w Window) GetOverlappingBounds(b Bounds) []Bounds + func (w Window) IsValid() error