universe

Feb 23, 2023

Changes in this version

type HistogramQuantileOpSpec

+ OnNonmonotonic string

type HistogramQuantileProcedureSpec

+ OnNonmonotonic string

Aug 22, 2022

Changes in this version

type DropKeepMutator

+ func NewDropMutator(s *DropOpSpec) (*DropKeepMutator, error)

+ func NewKeepMutator(s *KeepOpSpec) (*DropKeepMutator, error)

Jul 29, 2022

Changes in this version

type RangeProcedureSpec

+ func (s *RangeProcedureSpec) PassThroughAttribute(attrKey string) bool

+ type RemoveRedundantSort struct

+ func (r RemoveRedundantSort) Name() string

+ func (r RemoveRedundantSort) Pattern() plan.Pattern

+ func (r RemoveRedundantSort) Rewrite(ctx context.Context, node plan.Node) (plan.Node, bool, error)

type SortedPivotProcedureSpec

+ func (s *SortedPivotProcedureSpec) OutputAttributes() plan.PhysicalAttributes

Jul 19, 2022

Changes in this version

type AggregateWindowProcedureSpec

+ ParallelMergeFactor int

+ func (s *AggregateWindowProcedureSpec) OutputAttributes() plan.PhysicalAttributes

+ func (s *AggregateWindowProcedureSpec) RequiredAttributes() []plan.PhysicalAttributes

type FilterProcedureSpec

+ func (s *FilterProcedureSpec) PassThroughAttribute(attrKey string) bool

type GroupProcedureSpec

+ func (s *GroupProcedureSpec) PassThroughAttribute(attrKey string) bool

type HoltWintersOpSpec

+ WithMinSSE bool

type HoltWintersProcedureSpec

+ WithMinSSE bool

type PartitionMergeProcedureSpec

+ Factor int

+ func (o *PartitionMergeProcedureSpec) OutputAttributes() plan.PhysicalAttributes

+ func (o *PartitionMergeProcedureSpec) RequiredAttributes() []plan.PhysicalAttributes

type SortProcedureSpec

+ func (s *SortProcedureSpec) OutputAttributes() plan.PhysicalAttributes

Jun 24, 2022

Changes in this version

type DerivativeOpSpec

+ InitialZero bool

type DerivativeProcedureSpec

+ InitialZero bool

May 23, 2022

Changes in this version

type HourSelectionOpSpec

+ Location string

+ Offset values.Duration

type HourSelectionProcedureSpec

+ Location string

+ Offset values.Duration

May 16, 2022

Changes in this version

type AggregateWindowProcedureSpec

+ AggregateKind plan.ProcedureKind

+ ForceAggregate bool

+ UseStart bool

+ ValueCol string

+ WindowSpec *WindowProcedureSpec

May 9, 2022

Changes in this version

+ func CreateColumnsOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

Mar 14, 2022

Changes in this version

+ func NewNarrowStateTrackingTransformation(ctx context.Context, spec *StateTrackingProcedureSpec, id execute.DatasetID, ...) (execute.Transformation, execute.Dataset, error)

Mar 3, 2022

Changes in this version

+ const AggregateWindowKind

+ const ParallelMergeKind

+ func NewNarrowFillTransformation(ctx context.Context, spec *FillProcedureSpec, id execute.DatasetID, ...) (execute.Transformation, execute.Dataset, error)

+ func NewNarrowLimitTransformation(spec *LimitProcedureSpec, id execute.DatasetID, mem *memory.Allocator) (execute.Transformation, execute.Dataset, error)

+ type AggregateWindowCreateEmptyRule struct

+ func (a AggregateWindowCreateEmptyRule) Name() string

+ func (a AggregateWindowCreateEmptyRule) Pattern() plan.Pattern

+ func (a AggregateWindowCreateEmptyRule) Rewrite(ctx context.Context, node plan.Node) (plan.Node, bool, error)

+ type AggregateWindowProcedureSpec struct

+ func (s *AggregateWindowProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *AggregateWindowProcedureSpec) Kind() plan.ProcedureKind

+ type AggregateWindowRule struct

+ func (a AggregateWindowRule) Name() string

+ func (a AggregateWindowRule) Pattern() plan.Pattern

+ func (a AggregateWindowRule) Rewrite(ctx context.Context, node plan.Node) (plan.Node, bool, error)

+ type PartitionMergeProcedureSpec struct

+ func (o *PartitionMergeProcedureSpec) Copy() plan.ProcedureSpec

+ func (o *PartitionMergeProcedureSpec) Kind() plan.ProcedureKind

+ type PartitionMergeTransformation struct

+ func NewPartitionMergeTransformation(ctx context.Context, dataset *execute.PassthroughDataset, ...) (*PartitionMergeTransformation, error)

+ func (t *PartitionMergeTransformation) Finish(id execute.DatasetID, err error)

+ func (t *PartitionMergeTransformation) Process(id execute.DatasetID, tbl flux.Table) error

+ func (t *PartitionMergeTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error

+ func (t *PartitionMergeTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error

+ func (t *PartitionMergeTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error

type QuantileAggState

+ func (s *QuantileAggState) DoInt(vs *array.Int)

+ func (s *QuantileAggState) DoUInt(vs *array.Uint)

Feb 22, 2022

Changes in this version

+ func NewNarrowDifferenceTransformation(spec *DifferenceProcedureSpec, id execute.DatasetID, alloc memory.Allocator) (execute.Transformation, execute.Dataset, error)

Jan 12, 2022

Changes in this version

+ const SortLimitKind

+ func NewSortLimitTransformation(id execute.DatasetID, spec *SortLimitProcedureSpec, mem memory.Allocator) (execute.Transformation, execute.Dataset, error)

+ type SortLimitProcedureSpec struct

+ N int64

+ func (s *SortLimitProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *SortLimitProcedureSpec) Kind() plan.ProcedureKind

+ type SortLimitRule struct

+ func (s SortLimitRule) Name() string

+ func (s SortLimitRule) Pattern() plan.Pattern

+ func (s SortLimitRule) Rewrite(ctx context.Context, node plan.Node) (plan.Node, bool, error)

Jan 7, 2022

Changes in this version

type QuantileAgg

+ func (a *QuantileAgg) Close() error

type QuantileAggState

+ func (s *QuantileAggState) Close() error

Nov 20, 2021

Changes in this version

type DifferenceOpSpec

+ InitialZero bool

type DifferenceProcedureSpec

+ InitialZero bool

Oct 18, 2021

Changes in this version

type QuantileAgg

+ func (a *QuantileAgg) Dispose()

+ type QuantileAggState struct

+ func (s *QuantileAggState) Dispose()

+ func (s *QuantileAggState) DoFloat(vs *array.Float)

+ func (s *QuantileAggState) IsNull() bool

+ func (s *QuantileAggState) Type() flux.ColType

+ func (s *QuantileAggState) ValueFloat() float64

Oct 4, 2021

Changes in this version

type WindowOpSpec

+ Location string

Aug 11, 2021

Changes in this version

+ const SortedPivotKind

Jul 16, 2021

Changes in this version

+ type SortedPivotProcedureSpec struct

+ ColumnKey []string

+ RowKey []string

+ ValueColumn string

+ func (s *SortedPivotProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *SortedPivotProcedureSpec) Kind() plan.ProcedureKind

May 28, 2021

Changes in this version

+ type OptimizeSortRule struct

+ func (r OptimizeSortRule) Name() string

+ func (r OptimizeSortRule) Pattern() plan.Pattern

+ func (r OptimizeSortRule) Rewrite(ctx context.Context, node plan.Node) (plan.Node, bool, error)

+ type OptimizeWindowRule struct

+ func (r OptimizeWindowRule) Name() string

+ func (r OptimizeWindowRule) Pattern() plan.Pattern

+ func (r OptimizeWindowRule) Rewrite(ctx context.Context, node plan.Node) (plan.Node, bool, error)

type SortProcedureSpec

+ Optimize bool

type WindowProcedureSpec

+ Optimize bool

Apr 6, 2021

Changes in this version

+ func CreateDistinctOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreateFillOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreateFirstOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreateHistogramOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreateLastOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreateMaxOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreateMinOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreateUniqueOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

Mar 6, 2021

Changes in this version

+ func CreateCountOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreateHistogramQuantileOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreateMeanOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreateModeOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreateQuantileOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreateSkewOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreateSpreadOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreateStddevOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreateSumOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreatekamaOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

Feb 18, 2021

Changes in this version

+ func CreateIntegralOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

+ func CreateWindowOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error)

type QuantileAgg

+ func NewQuantileAgg(q, comp float64) *QuantileAgg

+ func (a *QuantileAgg) Recycle() *QuantileAgg

Feb 3, 2021

Changes in this version

+ const WindowIntervalKind

+ func NewIntervalFixedWindowTransformation(d execute.Dataset, cache execute.TableBuilderCache, bounds interval.Bounds, ...) execute.Transformation

+ type WindowIntervalOpSpec struct

+ CreateEmpty bool

+ Every flux.Duration

+ Offset flux.Duration

+ Period flux.Duration

+ StartColumn string

+ StopColumn string

+ TimeColumn string

+ func (s *WindowIntervalOpSpec) Kind() flux.OperationKind

+ type WindowIntervalProcedureSpec struct

+ CreateEmpty bool

+ StartColumn string

+ StopColumn string

+ TimeColumn string

+ Window plan.WindowSpec

+ func (s *WindowIntervalProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *WindowIntervalProcedureSpec) Kind() plan.ProcedureKind

Sep 1, 2020

Changes in this version

type IntegralOpSpec

+ Interpolate string

type IntegralProcedureSpec

+ Interpolate bool

Aug 24, 2020

Changes in this version

+ const DieKind

+ func Die() values.Function

Jul 27, 2020

Changes in this version

type DualImplProcedureSpec

+ func (s *DualImplProcedureSpec) PlanDetails() string

Jul 10, 2020

Changes in this version

+ type MergeFiltersRule struct

+ func (MergeFiltersRule) Name() string

+ func (MergeFiltersRule) Pattern() plan.Pattern

+ func (MergeFiltersRule) Rewrite(ctx context.Context, filterNode plan.Node) (plan.Node, bool, error)

Jun 30, 2020

Changes in this version

+ func NewDeprecatedSchemaMutationTransformation(ctx context.Context, spec plan.ProcedureSpec, d execute.Dataset, ...) (execute.Transformation, error)

Jun 8, 2020

Changes in this version

+ func NewDeprecatedFillTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *FillProcedureSpec) *deprecatedFillTransformation

+ func UseDeprecatedImpl(spec plan.ProcedureSpec)

+ type DualImplProcedureSpec struct

+ UseDeprecated bool

+ func (s *DualImplProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *DualImplProcedureSpec) Kind() plan.ProcedureKind

May 28, 2020

Changes in this version

+ func NewFindColumnFunction() values.Value

+ func NewFindRecordFunction() values.Value

type MutationRegistrar

+ Type semantic.MonoType

Jan 6, 2020

Changes in this version

type FilterOpSpec

+ OnEmpty string

type FilterProcedureSpec

+ KeepEmptyTables bool

Dec 2, 2019

Changes in this version

type PivotProcedureSpec

+ IsKeyColumnFunc func(label string) bool

+ IsSortedByFunc func(cols []string, desc bool) bool

Oct 11, 2019

Changes in this version

type FilterProcedureSpec

+ func (s *FilterProcedureSpec) PlanDetails() string

Sep 19, 2019

Changes in this version

+ var FluxTestPackages = []*ast.Package

Aug 20, 2019

Changes in this version

+ const TripleExponentialDerivativeKind

+ func NewTripleExponentialDerivativeTransformation(d execute.Dataset, cache execute.TableBuilderCache, alloc *memory.Allocator, ...) *tripleExponentialDerivativeTransformation

+ func NewkamaTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *KamaProcedureSpec) *kamaTransformation

+ type KamaOpSpec struct

+ Column string

+ N int64

+ func (s *KamaOpSpec) Kind() flux.OperationKind

+ type KamaProcedureSpec struct

+ Column string

+ N int64

+ func (s *KamaProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *KamaProcedureSpec) Kind() plan.ProcedureKind

+ func (s *KamaProcedureSpec) TriggerSpec() plan.TriggerSpec

+ type TripleExponentialDerivativeOpSpec struct

+ N int64

+ func (s *TripleExponentialDerivativeOpSpec) Kind() flux.OperationKind

+ type TripleExponentialDerivativeProcedureSpec struct

+ N int64

+ func (s *TripleExponentialDerivativeProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *TripleExponentialDerivativeProcedureSpec) Kind() plan.ProcedureKind

+ func (s *TripleExponentialDerivativeProcedureSpec) TriggerSpec() plan.TriggerSpec

Aug 12, 2019

Changes in this version

+ const ChandeMomentumOscillatorKind

+ const HourSelectionKind

+ const TailKind

+ func NewChandeMomentumOscillatorTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *chandeMomentumOscillatorTransformation

+ func NewHourSelectionTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *hourSelectionTransformation

+ func NewTailTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *TailProcedureSpec) *tailTransformation

+ type ChandeMomentumOscillatorOpSpec struct

+ Columns []string

+ N int64

+ func (s *ChandeMomentumOscillatorOpSpec) Kind() flux.OperationKind

+ type ChandeMomentumOscillatorProcedureSpec struct

+ Columns []string

+ N int64

+ func (s *ChandeMomentumOscillatorProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *ChandeMomentumOscillatorProcedureSpec) Kind() plan.ProcedureKind

+ func (s *ChandeMomentumOscillatorProcedureSpec) TriggerSpec() plan.TriggerSpec

+ type HourSelectionOpSpec struct

+ Start int64

+ Stop int64

+ TimeColumn string

+ func (s *HourSelectionOpSpec) Kind() flux.OperationKind

+ type HourSelectionProcedureSpec struct

+ Start int64

+ Stop int64

+ TimeColumn string

+ func (s *HourSelectionProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *HourSelectionProcedureSpec) Kind() plan.ProcedureKind

+ func (s *HourSelectionProcedureSpec) TriggerSpec() plan.TriggerSpec

+ type TailOpSpec struct

+ N int64

+ Offset int64

+ func (s *TailOpSpec) Kind() flux.OperationKind

+ type TailProcedureSpec struct

+ N int64

+ Offset int64

+ func (s *TailProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *TailProcedureSpec) Kind() plan.ProcedureKind

+ func (s *TailProcedureSpec) TriggerSpec() plan.TriggerSpec

Aug 5, 2019

Changes in this version

+ const HoltWintersKind

+ const RelativeStrengthIndexKind

+ func NewHoltWintersTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *holtWintersTransformation

+ func NewRelativeStrengthIndexTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *relativeStrengthIndexTransformation

type DifferenceOpSpec

+ KeepFirst bool

type DifferenceProcedureSpec

+ KeepFirst bool

type FirstSelector

+ func (s *FirstSelector) DoTime(vs *array.Int64) []int

+ func (s *FirstSelector) NewTimeSelector() execute.DoTimeIndexSelector

+ type HoltWintersOpSpec struct

+ Column string

+ Interval flux.Duration

+ N int64

+ S int64

+ TimeColumn string

+ WithFit bool

+ func (s *HoltWintersOpSpec) Kind() flux.OperationKind

+ type HoltWintersProcedureSpec struct

+ Column string

+ Interval flux.Duration

+ N int64

+ S int64

+ TimeColumn string

+ WithFit bool

+ func (s *HoltWintersProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *HoltWintersProcedureSpec) Kind() plan.ProcedureKind

+ func (s *HoltWintersProcedureSpec) TriggerSpec() plan.TriggerSpec

type LastSelector

+ func (s *LastSelector) DoTime(vs *array.Int64, cr flux.ColReader)

+ func (s *LastSelector) NewTimeSelector() execute.DoTimeRowSelector

type MaxSelector

+ func (s *MaxSelector) NewTimeSelector() execute.DoTimeRowSelector

+ type MaxTimeSelector struct

+ func (s *MaxTimeSelector) DoTime(vs *array.Int64, cr flux.ColReader)

type MinSelector

+ func (s *MinSelector) NewTimeSelector() execute.DoTimeRowSelector

+ type MinTimeSelector struct

+ func (s *MinTimeSelector) DoTime(vs *array.Int64, cr flux.ColReader)

+ type RelativeStrengthIndexOpSpec struct

+ Columns []string

+ N int64

+ func (s *RelativeStrengthIndexOpSpec) Kind() flux.OperationKind

+ type RelativeStrengthIndexProcedureSpec struct

+ Columns []string

+ N int64

+ func (s *RelativeStrengthIndexProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *RelativeStrengthIndexProcedureSpec) Kind() plan.ProcedureKind

+ func (s *RelativeStrengthIndexProcedureSpec) TriggerSpec() plan.TriggerSpec

type SampleSelector

+ func (s *SampleSelector) DoTime(vs *array.Int64) []int

+ func (s *SampleSelector) NewTimeSelector() execute.DoTimeIndexSelector

Jul 22, 2019

Changes in this version

+ const ExponentialMovingAverageKind

+ func NewExponentialMovingAverageTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *exponentialMovingAverageTransformation

+ type ExponentialMovingAverageOpSpec struct

+ Columns []string

+ N int64

+ func (s *ExponentialMovingAverageOpSpec) Kind() flux.OperationKind

+ type ExponentialMovingAverageProcedureSpec struct

+ Columns []string

+ N int64

+ func (s *ExponentialMovingAverageProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *ExponentialMovingAverageProcedureSpec) Kind() plan.ProcedureKind

+ func (s *ExponentialMovingAverageProcedureSpec) TriggerSpec() plan.TriggerSpec

Jul 9, 2019

Changes in this version

+ const ElapsedKind

+ const ModeKind

+ const MovingAverageKind

+ func NewElapsedTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *ElapsedProcedureSpec) *elapsedTransformation

+ func NewModeTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *ModeProcedureSpec) *modeTransformation

+ func NewMovingAverageTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *movingAverageTransformation

+ type ElapsedOpSpec struct

+ ColumnName string

+ TimeColumn string

+ Unit flux.Duration

+ func (s *ElapsedOpSpec) Kind() flux.OperationKind

+ type ElapsedProcedureSpec struct

+ ColumnName string

+ TimeColumn string

+ Unit flux.Duration

+ func (s *ElapsedProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *ElapsedProcedureSpec) Kind() plan.ProcedureKind

+ type ModeOpSpec struct

+ Column string

+ func (s *ModeOpSpec) Kind() flux.OperationKind

+ type ModeProcedureSpec struct

+ Column string

+ func (s *ModeProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *ModeProcedureSpec) Kind() plan.ProcedureKind

+ func (s *ModeProcedureSpec) TriggerSpec() plan.TriggerSpec

+ type MovingAverageOpSpec struct

+ Columns []string

+ N int64

+ func (s *MovingAverageOpSpec) Kind() flux.OperationKind

+ type MovingAverageProcedureSpec struct

+ Columns []string

+ N int64

+ func (s *MovingAverageProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *MovingAverageProcedureSpec) Kind() plan.ProcedureKind

+ func (s *MovingAverageProcedureSpec) TriggerSpec() plan.TriggerSpec

Jul 2, 2019

Changes in this version

+ func MakeLengthFunc() values.Function

May 14, 2019

Changes in this version

+ func NewGetColumnFunction() values.Value

+ func NewGetRecordFunction() values.Value

+ func NewTableFindFunction() values.Value

Apr 24, 2019

Changes in this version

type StddevAgg

+ Mode string

type StddevOpSpec

+ Mode string

type StddevProcedureSpec

+ Mode string

Apr 17, 2019

Changes in this version

type CovarianceOpSpec

+ Columns []string

type CovarianceProcedureSpec

+ Columns []string

Mar 29, 2019

Changes in this version

+ const ExactQuantileAggKind

+ const ExactQuantileSelectKind

+ const QuantileKind

+ type ExactQuantileAgg struct

+ Quantile float64

+ func (a *ExactQuantileAgg) Copy() *ExactQuantileAgg

+ func (a *ExactQuantileAgg) DoFloat(vs *array.Float64)

+ func (a *ExactQuantileAgg) IsNull() bool

+ func (a *ExactQuantileAgg) NewBoolAgg() execute.DoBoolAgg

+ func (a *ExactQuantileAgg) NewFloatAgg() execute.DoFloatAgg

+ func (a *ExactQuantileAgg) NewIntAgg() execute.DoIntAgg

+ func (a *ExactQuantileAgg) NewStringAgg() execute.DoStringAgg

+ func (a *ExactQuantileAgg) NewUIntAgg() execute.DoUIntAgg

+ func (a *ExactQuantileAgg) Type() flux.ColType

+ func (a *ExactQuantileAgg) ValueFloat() float64

+ type ExactQuantileAggProcedureSpec struct

+ Quantile float64

+ func (s *ExactQuantileAggProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *ExactQuantileAggProcedureSpec) Kind() plan.ProcedureKind

+ func (s *ExactQuantileAggProcedureSpec) TriggerSpec() plan.TriggerSpec

+ type ExactQuantileSelectProcedureSpec struct

+ Quantile float64

+ func (s *ExactQuantileSelectProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *ExactQuantileSelectProcedureSpec) Kind() plan.ProcedureKind

+ func (s *ExactQuantileSelectProcedureSpec) TriggerSpec() plan.TriggerSpec

+ type ExactQuantileSelectorTransformation struct

+ func NewExactQuantileSelectorTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *ExactQuantileSelectorTransformation

+ func (t *ExactQuantileSelectorTransformation) Finish(id execute.DatasetID, err error)

+ func (t *ExactQuantileSelectorTransformation) Process(id execute.DatasetID, tbl flux.Table) error

+ func (t *ExactQuantileSelectorTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error

+ func (t *ExactQuantileSelectorTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error

+ func (t *ExactQuantileSelectorTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error

+ type QuantileAgg struct

+ Compression float64

+ Quantile float64

+ func (a *QuantileAgg) Copy() *QuantileAgg

+ func (a *QuantileAgg) DoFloat(vs *array.Float64)

+ func (a *QuantileAgg) IsNull() bool

+ func (a *QuantileAgg) NewBoolAgg() execute.DoBoolAgg

+ func (a *QuantileAgg) NewFloatAgg() execute.DoFloatAgg

+ func (a *QuantileAgg) NewIntAgg() execute.DoIntAgg

+ func (a *QuantileAgg) NewStringAgg() execute.DoStringAgg

+ func (a *QuantileAgg) NewUIntAgg() execute.DoUIntAgg

+ func (a *QuantileAgg) Type() flux.ColType

+ func (a *QuantileAgg) ValueFloat() float64

+ type QuantileOpSpec struct

+ Compression float64

+ Method string

+ Quantile float64

+ func (s *QuantileOpSpec) Kind() flux.OperationKind

+ type TDigestQuantileProcedureSpec struct

+ Compression float64

+ Quantile float64

+ func (s *TDigestQuantileProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *TDigestQuantileProcedureSpec) Kind() plan.ProcedureKind

+ func (s *TDigestQuantileProcedureSpec) TriggerSpec() plan.TriggerSpec

Mar 26, 2019

Changes in this version

+ const ReduceKind

+ func NewReduceTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *ReduceProcedureSpec) (*reduceTransformation, error)

+ type ReduceOpSpec struct

+ Fn *semantic.FunctionExpression

+ Identity map[string]string

+ ReducerType semantic.Type

+ func (s *ReduceOpSpec) Kind() flux.OperationKind

+ type ReduceProcedureSpec struct

+ Fn *semantic.FunctionExpression

+ Identity map[string]string

+ ReducerType semantic.Type

+ func (s *ReduceProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *ReduceProcedureSpec) Kind() plan.ProcedureKind

Mar 18, 2019

Changes in this version

type CountProcedureSpec

+ func (s *CountProcedureSpec) TriggerSpec() plan.TriggerSpec

type CovarianceProcedureSpec

+ func (s *CovarianceProcedureSpec) TriggerSpec() plan.TriggerSpec

type CumulativeSumProcedureSpec

+ func (s *CumulativeSumProcedureSpec) TriggerSpec() plan.TriggerSpec

type DerivativeProcedureSpec

+ func (s *DerivativeProcedureSpec) TriggerSpec() plan.TriggerSpec

type DifferenceProcedureSpec

+ func (s *DifferenceProcedureSpec) TriggerSpec() plan.TriggerSpec

type DistinctProcedureSpec

+ func (s *DistinctProcedureSpec) TriggerSpec() plan.TriggerSpec

type ExactPercentileAggProcedureSpec

+ func (s *ExactPercentileAggProcedureSpec) TriggerSpec() plan.TriggerSpec

type ExactPercentileSelectProcedureSpec

+ func (s *ExactPercentileSelectProcedureSpec) TriggerSpec() plan.TriggerSpec

type FilterProcedureSpec

+ func (s *FilterProcedureSpec) TriggerSpec() plan.TriggerSpec

type FirstProcedureSpec

+ func (s *FirstProcedureSpec) TriggerSpec() plan.TriggerSpec

type IntegralProcedureSpec

+ func (s *IntegralProcedureSpec) TriggerSpec() plan.TriggerSpec

type KeyValuesProcedureSpec

+ func (s *KeyValuesProcedureSpec) TriggerSpec() plan.TriggerSpec

type KeysProcedureSpec

+ func (s *KeysProcedureSpec) TriggerSpec() plan.TriggerSpec

type LastProcedureSpec

+ func (s *LastProcedureSpec) TriggerSpec() plan.TriggerSpec

type LimitProcedureSpec

+ func (s *LimitProcedureSpec) TriggerSpec() plan.TriggerSpec

type MaxProcedureSpec

+ func (s *MaxProcedureSpec) TriggerSpec() plan.TriggerSpec

type MeanProcedureSpec

+ func (s *MeanProcedureSpec) TriggerSpec() plan.TriggerSpec

type MinProcedureSpec

+ func (s *MinProcedureSpec) TriggerSpec() plan.TriggerSpec

type RangeProcedureSpec

+ func (s *RangeProcedureSpec) TriggerSpec() plan.TriggerSpec

type SampleProcedureSpec

+ func (s *SampleProcedureSpec) TriggerSpec() plan.TriggerSpec

type ShiftProcedureSpec

+ func (s *ShiftProcedureSpec) TriggerSpec() plan.TriggerSpec

type SkewProcedureSpec

+ func (s *SkewProcedureSpec) TriggerSpec() plan.TriggerSpec

type SortProcedureSpec

+ func (s *SortProcedureSpec) TriggerSpec() plan.TriggerSpec

type SpreadProcedureSpec

+ func (s *SpreadProcedureSpec) TriggerSpec() plan.TriggerSpec

type StateTrackingProcedureSpec

+ func (s *StateTrackingProcedureSpec) TriggerSpec() plan.TriggerSpec

type StddevProcedureSpec

+ func (s *StddevProcedureSpec) TriggerSpec() plan.TriggerSpec

type SumProcedureSpec

+ func (s *SumProcedureSpec) TriggerSpec() plan.TriggerSpec

type TDigestPercentileProcedureSpec

+ func (s *TDigestPercentileProcedureSpec) TriggerSpec() plan.TriggerSpec

type UniqueProcedureSpec

+ func (s *UniqueProcedureSpec) TriggerSpec() plan.TriggerSpec

+ type WindowTriggerPhysicalRule struct

+ func (WindowTriggerPhysicalRule) Name() string

+ func (WindowTriggerPhysicalRule) Pattern() plan.Pattern

+ func (WindowTriggerPhysicalRule) Rewrite(window plan.PlanNode) (plan.PlanNode, bool, error)

Feb 8, 2019

Changes in this version

+ func MakeContainsFunc() values.Function

type WindowOpSpec

+ Offset flux.Duration

Jan 16, 2019

Changes in this version

+ func NewUnionTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *UnionProcedureSpec, ...) *unionTransformation

+ type RemoveTrivialFilterRule struct

+ func (RemoveTrivialFilterRule) Name() string

+ func (RemoveTrivialFilterRule) Pattern() plan.Pattern

+ func (RemoveTrivialFilterRule) Rewrite(filterNode plan.PlanNode) (plan.PlanNode, bool, error)

Jan 15, 2019

Changes in this version

+ const ColumnsKind

+ const CountKind

+ const CovarianceKind

+ const CumulativeSumKind

+ const DefaultUpperBoundColumnLabel

+ const DerivativeKind

+ const DifferenceKind

+ const DistinctKind

+ const DropKind

+ const DuplicateKind

+ const ExactPercentileAggKind

+ const ExactPercentileSelectKind

+ const FillKind

+ const FilterKind

+ const FirstKind

+ const GroupKind

+ const HistogramKind

+ const HistogramQuantileKind

+ const IntegralKind

+ const JoinKind

+ const KeepKind

+ const KeyValuesKind

+ const KeysKind

+ const LastKind

+ const LimitKind

+ const MapKind

+ const MaxKind

+ const MeanKind

+ const MergeJoinKind

+ const MinKind

+ const PercentileKind

+ const PivotKind

+ const RangeKind

+ const RenameKind

+ const SampleKind

+ const SchemaMutationKind

+ const SetKind

+ const ShiftKind

+ const SkewKind

+ const SortKind

+ const SpreadKind

+ const StateTrackingKind

+ const StddevKind

+ const SumKind

+ const UnionKind

+ const UniqueKind

+ const WindowKind

+ const YieldKind

+ var Registrars = []MutationRegistrar

+ var SchemaMutationOps = []flux.OperationKind

+ func NewColumnsTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *ColumnsProcedureSpec) *columnsTransformation

+ func NewCumulativeSumTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *cumulativeSumTransformation

+ func NewDerivativeTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *derivativeTransformation

+ func NewDifferenceTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *differenceTransformation

+ func NewDistinctTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *distinctTransformation

+ func NewFillTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *FillProcedureSpec) *fillTransformation

+ func NewFilterTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *FilterProcedureSpec) (*filterTransformation, error)

+ func NewFixedWindowTransformation(d execute.Dataset, cache execute.TableBuilderCache, bounds execute.Bounds, ...) execute.Transformation

+ func NewGroupTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *GroupProcedureSpec) *groupTransformation

+ func NewHistogramTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *histogramTransformation

+ func NewHistorgramQuantileTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) execute.Transformation

+ func NewIntegralTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *integralTransformation

+ func NewKeyValuesTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *keyValuesTransformation

+ func NewKeysTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *KeysProcedureSpec) *keysTransformation

+ func NewLimitTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *LimitProcedureSpec) *limitTransformation

+ func NewMapTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *MapProcedureSpec) (*mapTransformation, error)

+ func NewMergeJoinTransformation(d execute.Dataset, cache *MergeJoinCache, spec *MergeJoinProcedureSpec, ...) *mergeJoinTransformation

+ func NewPivotTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *PivotProcedureSpec) *pivotTransformation

+ func NewRangeTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *RangeProcedureSpec, ...) (*rangeTransformation, error)

+ func NewSchemaMutationTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec plan.ProcedureSpec) (*schemaMutationTransformation, error)

+ func NewSetTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *SetProcedureSpec) execute.Transformation

+ func NewShiftTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *ShiftProcedureSpec) *shiftTransformation

+ func NewSortTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *SortProcedureSpec) *sortTransformation

+ func NewStateTrackingTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) (*stateTrackingTransformation, error)

+ func NewUniqueTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *UniqueProcedureSpec) *uniqueTransformation

+ type BuilderContext struct

+ ColIdxMap []int

+ TableColumns []flux.ColMeta

+ TableKey flux.GroupKey

+ func NewBuilderContext(tbl flux.Table) *BuilderContext

+ func (b *BuilderContext) ColMap() []int

+ func (b *BuilderContext) Cols() []flux.ColMeta

+ func (b *BuilderContext) Key() flux.GroupKey

+ type ColumnsOpSpec struct

+ Column string

+ func (s *ColumnsOpSpec) Kind() flux.OperationKind

+ type ColumnsProcedureSpec struct

+ Column string

+ func (s *ColumnsProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *ColumnsProcedureSpec) Kind() plan.ProcedureKind

+ type CountAgg struct

+ func (a *CountAgg) DoBool(vs *array.Boolean)

+ func (a *CountAgg) DoFloat(vs *array.Float64)

+ func (a *CountAgg) DoInt(vs *array.Int64)

+ func (a *CountAgg) DoString(vs *array.Binary)

+ func (a *CountAgg) DoUInt(vs *array.Uint64)

+ func (a *CountAgg) IsNull() bool

+ func (a *CountAgg) NewBoolAgg() execute.DoBoolAgg

+ func (a *CountAgg) NewFloatAgg() execute.DoFloatAgg

+ func (a *CountAgg) NewIntAgg() execute.DoIntAgg

+ func (a *CountAgg) NewStringAgg() execute.DoStringAgg

+ func (a *CountAgg) NewUIntAgg() execute.DoUIntAgg

+ func (a *CountAgg) Type() flux.ColType

+ func (a *CountAgg) ValueInt() int64

+ type CountOpSpec struct

+ func (s *CountOpSpec) Kind() flux.OperationKind

+ type CountProcedureSpec struct

+ func (s *CountProcedureSpec) AggregateMethod() string

+ func (s *CountProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *CountProcedureSpec) Kind() plan.ProcedureKind

+ func (s *CountProcedureSpec) ReAggregateSpec() plan.ProcedureSpec

+ type CovarianceOpSpec struct

+ PearsonCorrelation bool

+ ValueDst string

+ func (s *CovarianceOpSpec) Kind() flux.OperationKind

+ type CovarianceProcedureSpec struct

+ PearsonCorrelation bool

+ ValueLabel string

+ func (s *CovarianceProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *CovarianceProcedureSpec) Kind() plan.ProcedureKind

+ type CovarianceTransformation struct

+ func NewCovarianceTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *CovarianceTransformation

+ func (t *CovarianceTransformation) DoFloat(xs, ys *array.Float64)

+ func (t *CovarianceTransformation) Finish(id execute.DatasetID, err error)

+ func (t *CovarianceTransformation) Process(id execute.DatasetID, tbl flux.Table) error

+ func (t *CovarianceTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error

+ func (t *CovarianceTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error

+ func (t *CovarianceTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error

+ type CumulativeSumOpSpec struct

+ Columns []string

+ func (s *CumulativeSumOpSpec) Kind() flux.OperationKind

+ type CumulativeSumProcedureSpec struct

+ Columns []string

+ func (s *CumulativeSumProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *CumulativeSumProcedureSpec) Kind() plan.ProcedureKind

+ type DerivativeOpSpec struct

+ Columns []string

+ NonNegative bool

+ TimeColumn string

+ Unit flux.Duration

+ func (s *DerivativeOpSpec) Kind() flux.OperationKind

+ type DerivativeProcedureSpec struct

+ Columns []string

+ NonNegative bool

+ TimeColumn string

+ Unit flux.Duration

+ func (s *DerivativeProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *DerivativeProcedureSpec) Kind() plan.ProcedureKind

+ type DifferenceOpSpec struct

+ Columns []string

+ NonNegative bool

+ func (s *DifferenceOpSpec) Kind() flux.OperationKind

+ type DifferenceProcedureSpec struct

+ Columns []string

+ NonNegative bool

+ func (s *DifferenceProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *DifferenceProcedureSpec) Kind() plan.ProcedureKind

+ type DistinctOpSpec struct

+ Column string

+ func (s *DistinctOpSpec) Kind() flux.OperationKind

+ type DistinctProcedureSpec struct

+ Column string

+ func (s *DistinctProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *DistinctProcedureSpec) Kind() plan.ProcedureKind

+ type DropKeepMutator struct

+ DropCols map[string]bool

+ FlipPredicate bool

+ Input values.Object

+ KeepCols map[string]bool

+ ParamName string

+ Predicate compiler.Func

+ func NewDropKeepMutator(qs flux.OperationSpec) (*DropKeepMutator, error)

+ func (m *DropKeepMutator) Mutate(ctx *BuilderContext) error

+ type DropOpSpec struct

+ Columns []string

+ Predicate *semantic.FunctionExpression

+ func (s *DropOpSpec) Copy() SchemaMutation

+ func (s *DropOpSpec) Kind() flux.OperationKind

+ func (s *DropOpSpec) Mutator() (SchemaMutator, error)

+ type DuplicateMutator struct

+ As string

+ Column string

+ func NewDuplicateMutator(qs flux.OperationSpec) (*DuplicateMutator, error)

+ func (m *DuplicateMutator) Mutate(ctx *BuilderContext) error

+ type DuplicateOpSpec struct

+ As string

+ Column string

+ func (s *DuplicateOpSpec) Copy() SchemaMutation

+ func (s *DuplicateOpSpec) Kind() flux.OperationKind

+ func (s *DuplicateOpSpec) Mutator() (SchemaMutator, error)

+ type ExactPercentileAgg struct

+ Quantile float64

+ func (a *ExactPercentileAgg) Copy() *ExactPercentileAgg

+ func (a *ExactPercentileAgg) DoFloat(vs *array.Float64)

+ func (a *ExactPercentileAgg) IsNull() bool

+ func (a *ExactPercentileAgg) NewBoolAgg() execute.DoBoolAgg

+ func (a *ExactPercentileAgg) NewFloatAgg() execute.DoFloatAgg

+ func (a *ExactPercentileAgg) NewIntAgg() execute.DoIntAgg

+ func (a *ExactPercentileAgg) NewStringAgg() execute.DoStringAgg

+ func (a *ExactPercentileAgg) NewUIntAgg() execute.DoUIntAgg

+ func (a *ExactPercentileAgg) Type() flux.ColType

+ func (a *ExactPercentileAgg) ValueFloat() float64

+ type ExactPercentileAggProcedureSpec struct

+ Percentile float64

+ func (s *ExactPercentileAggProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *ExactPercentileAggProcedureSpec) Kind() plan.ProcedureKind

+ type ExactPercentileSelectProcedureSpec struct

+ Percentile float64

+ func (s *ExactPercentileSelectProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *ExactPercentileSelectProcedureSpec) Kind() plan.ProcedureKind

+ type ExactPercentileSelectorTransformation struct

+ func NewExactPercentileSelectorTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *ExactPercentileSelectorTransformation

+ func (t *ExactPercentileSelectorTransformation) Finish(id execute.DatasetID, err error)

+ func (t *ExactPercentileSelectorTransformation) Process(id execute.DatasetID, tbl flux.Table) error

+ func (t *ExactPercentileSelectorTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error

+ func (t *ExactPercentileSelectorTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error

+ func (t *ExactPercentileSelectorTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error

+ type FillOpSpec struct

+ Column string

+ Type string

+ UsePrevious bool

+ Value string

+ func (s *FillOpSpec) Kind() flux.OperationKind

+ type FillProcedureSpec struct

+ Column string

+ UsePrevious bool

+ Value values.Value

+ func (s *FillProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *FillProcedureSpec) Kind() plan.ProcedureKind

+ type FilterOpSpec struct

+ Fn *semantic.FunctionExpression

+ func (s *FilterOpSpec) Kind() flux.OperationKind

+ type FilterProcedureSpec struct

+ Fn *semantic.FunctionExpression

+ func (s *FilterProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *FilterProcedureSpec) Kind() plan.ProcedureKind

+ type FirstOpSpec struct

+ func (s *FirstOpSpec) Kind() flux.OperationKind

+ type FirstProcedureSpec struct

+ func (s *FirstProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *FirstProcedureSpec) Kind() plan.ProcedureKind

+ type FirstSelector struct

+ func (s *FirstSelector) DoBool(vs *array.Boolean) []int

+ func (s *FirstSelector) DoFloat(vs *array.Float64) []int

+ func (s *FirstSelector) DoInt(vs *array.Int64) []int

+ func (s *FirstSelector) DoString(vs *array.Binary) []int

+ func (s *FirstSelector) DoUInt(vs *array.Uint64) []int

+ func (s *FirstSelector) NewBoolSelector() execute.DoBoolIndexSelector

+ func (s *FirstSelector) NewFloatSelector() execute.DoFloatIndexSelector

+ func (s *FirstSelector) NewIntSelector() execute.DoIntIndexSelector

+ func (s *FirstSelector) NewStringSelector() execute.DoStringIndexSelector

+ func (s *FirstSelector) NewUIntSelector() execute.DoUIntIndexSelector

+ type GroupOpSpec struct

+ Columns []string

+ Mode string

+ func (s *GroupOpSpec) Kind() flux.OperationKind

+ type GroupProcedureSpec struct

+ GroupKeys []string

+ GroupMode flux.GroupMode

+ func (s *GroupProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *GroupProcedureSpec) Kind() plan.ProcedureKind

+ type HistogramOpSpec struct

+ Bins []float64

+ Column string

+ CountColumn string

+ Normalize bool

+ UpperBoundColumn string

+ func (s *HistogramOpSpec) Kind() flux.OperationKind

+ type HistogramProcedureSpec struct

+ func (s *HistogramProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *HistogramProcedureSpec) Kind() plan.ProcedureKind

+ type HistogramQuantileOpSpec struct

+ CountColumn string

+ MinValue float64

+ Quantile float64

+ UpperBoundColumn string

+ ValueColumn string

+ func (s *HistogramQuantileOpSpec) Kind() flux.OperationKind

+ type HistogramQuantileProcedureSpec struct

+ CountColumn string

+ MinValue float64

+ Quantile float64

+ UpperBoundColumn string

+ ValueColumn string

+ func (s *HistogramQuantileProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *HistogramQuantileProcedureSpec) Kind() plan.ProcedureKind

+ type IntegralOpSpec struct

+ TimeColumn string

+ Unit flux.Duration

+ func (s *IntegralOpSpec) Kind() flux.OperationKind

+ type IntegralProcedureSpec struct

+ TimeColumn string

+ Unit flux.Duration

+ func (s *IntegralProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *IntegralProcedureSpec) Kind() plan.ProcedureKind

+ type JoinOpSpec struct

+ Method string

+ On []string

+ TableNames map[flux.OperationID]string

+ func (s *JoinOpSpec) Kind() flux.OperationKind

+ func (t *JoinOpSpec) IDer(ider flux.IDer)

+ type KeepOpSpec struct

+ Columns []string

+ Predicate *semantic.FunctionExpression

+ func (s *KeepOpSpec) Copy() SchemaMutation

+ func (s *KeepOpSpec) Kind() flux.OperationKind

+ func (s *KeepOpSpec) Mutator() (SchemaMutator, error)

+ type KeyValuesOpSpec struct

+ KeyColumns []string

+ PredicateFn *semantic.FunctionExpression

+ func (s *KeyValuesOpSpec) Kind() flux.OperationKind

+ type KeyValuesProcedureSpec struct

+ KeyColumns []string

+ Predicate *semantic.FunctionExpression

+ func (s *KeyValuesProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *KeyValuesProcedureSpec) Kind() plan.ProcedureKind

+ type KeysOpSpec struct

+ Column string

+ func (s *KeysOpSpec) Kind() flux.OperationKind

+ type KeysProcedureSpec struct

+ Column string

+ func (s *KeysProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *KeysProcedureSpec) Kind() plan.ProcedureKind

+ type LastOpSpec struct

+ func (s *LastOpSpec) Kind() flux.OperationKind

+ type LastProcedureSpec struct

+ func (s *LastProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *LastProcedureSpec) Kind() plan.ProcedureKind

+ type LastSelector struct

+ func (s *LastSelector) DoBool(vs *array.Boolean, cr flux.ColReader)

+ func (s *LastSelector) DoFloat(vs *array.Float64, cr flux.ColReader)

+ func (s *LastSelector) DoInt(vs *array.Int64, cr flux.ColReader)

+ func (s *LastSelector) DoString(vs *array.Binary, cr flux.ColReader)

+ func (s *LastSelector) DoUInt(vs *array.Uint64, cr flux.ColReader)

+ func (s *LastSelector) NewBoolSelector() execute.DoBoolRowSelector

+ func (s *LastSelector) NewFloatSelector() execute.DoFloatRowSelector

+ func (s *LastSelector) NewIntSelector() execute.DoIntRowSelector

+ func (s *LastSelector) NewStringSelector() execute.DoStringRowSelector

+ func (s *LastSelector) NewUIntSelector() execute.DoUIntRowSelector

+ func (s *LastSelector) Rows() []execute.Row

+ type LimitOpSpec struct

+ N int64

+ Offset int64

+ func (s *LimitOpSpec) Kind() flux.OperationKind

+ type LimitProcedureSpec struct

+ N int64

+ Offset int64

+ func (s *LimitProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *LimitProcedureSpec) Kind() plan.ProcedureKind

+ type MapOpSpec struct

+ Fn *semantic.FunctionExpression

+ MergeKey bool

+ func (s *MapOpSpec) Kind() flux.OperationKind

+ type MapProcedureSpec struct

+ Fn *semantic.FunctionExpression

+ MergeKey bool

+ func (s *MapProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *MapProcedureSpec) Kind() plan.ProcedureKind

+ type MaxFloatSelector struct

+ func (s *MaxFloatSelector) DoFloat(vs *array.Float64, cr flux.ColReader)

+ type MaxIntSelector struct

+ func (s *MaxIntSelector) DoInt(vs *array.Int64, cr flux.ColReader)

+ type MaxOpSpec struct

+ func (s *MaxOpSpec) Kind() flux.OperationKind

+ type MaxProcedureSpec struct

+ func (s *MaxProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *MaxProcedureSpec) Kind() plan.ProcedureKind

+ type MaxSelector struct

+ func (s *MaxSelector) NewBoolSelector() execute.DoBoolRowSelector

+ func (s *MaxSelector) NewFloatSelector() execute.DoFloatRowSelector

+ func (s *MaxSelector) NewIntSelector() execute.DoIntRowSelector

+ func (s *MaxSelector) NewStringSelector() execute.DoStringRowSelector

+ func (s *MaxSelector) NewUIntSelector() execute.DoUIntRowSelector

+ func (s *MaxSelector) Rows() []execute.Row

+ type MaxUIntSelector struct

+ func (s *MaxUIntSelector) DoUInt(vs *array.Uint64, cr flux.ColReader)

+ type MeanAgg struct

+ func (a *MeanAgg) DoFloat(vs *array.Float64)

+ func (a *MeanAgg) DoInt(vs *array.Int64)

+ func (a *MeanAgg) DoUInt(vs *array.Uint64)

+ func (a *MeanAgg) IsNull() bool

+ func (a *MeanAgg) NewBoolAgg() execute.DoBoolAgg

+ func (a *MeanAgg) NewFloatAgg() execute.DoFloatAgg

+ func (a *MeanAgg) NewIntAgg() execute.DoIntAgg

+ func (a *MeanAgg) NewStringAgg() execute.DoStringAgg

+ func (a *MeanAgg) NewUIntAgg() execute.DoUIntAgg

+ func (a *MeanAgg) Type() flux.ColType

+ func (a *MeanAgg) ValueFloat() float64

+ type MeanOpSpec struct

+ func (s *MeanOpSpec) Kind() flux.OperationKind

+ type MeanProcedureSpec struct

+ func (s *MeanProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *MeanProcedureSpec) Kind() plan.ProcedureKind

+ type MergeGroupRule struct

+ func (r MergeGroupRule) Name() string

+ func (r MergeGroupRule) Pattern() plan.Pattern

+ func (r MergeGroupRule) Rewrite(lastGroup plan.PlanNode) (plan.PlanNode, bool, error)

+ type MergeJoinCache struct

+ func NewMergeJoinCache(alloc *memory.Allocator, datasetIDs []execute.DatasetID, ...) *MergeJoinCache

+ func (c *MergeJoinCache) DiscardTable(key flux.GroupKey)

+ func (c *MergeJoinCache) ExpireTable(key flux.GroupKey)

+ func (c *MergeJoinCache) ForEach(f func(flux.GroupKey))

+ func (c *MergeJoinCache) ForEachWithContext(f func(flux.GroupKey, execute.Trigger, execute.TableContext))

+ func (c *MergeJoinCache) SetTriggerSpec(spec flux.TriggerSpec)

+ func (c *MergeJoinCache) Table(key flux.GroupKey) (flux.Table, error)

+ type MergeJoinProcedureSpec struct

+ On []string

+ TableNames []string

+ func (s *MergeJoinProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *MergeJoinProcedureSpec) Kind() plan.ProcedureKind

+ type MinFloatSelector struct

+ func (s *MinFloatSelector) DoFloat(vs *array.Float64, cr flux.ColReader)

+ type MinIntSelector struct

+ func (s *MinIntSelector) DoInt(vs *array.Int64, cr flux.ColReader)

+ type MinOpSpec struct

+ func (s *MinOpSpec) Kind() flux.OperationKind

+ type MinProcedureSpec struct

+ func (s *MinProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *MinProcedureSpec) Kind() plan.ProcedureKind

+ type MinSelector struct

+ func (s *MinSelector) NewBoolSelector() execute.DoBoolRowSelector

+ func (s *MinSelector) NewFloatSelector() execute.DoFloatRowSelector

+ func (s *MinSelector) NewIntSelector() execute.DoIntRowSelector

+ func (s *MinSelector) NewStringSelector() execute.DoStringRowSelector

+ func (s *MinSelector) NewUIntSelector() execute.DoUIntRowSelector

+ func (s *MinSelector) Rows() []execute.Row

+ type MinUIntSelector struct

+ func (s *MinUIntSelector) DoUInt(vs *array.Uint64, cr flux.ColReader)

+ type MutationRegistrar struct

+ Args map[string]semantic.PolyType

+ Create flux.CreateOperationSpec

+ Kind flux.OperationKind

+ New flux.NewOperationSpec

+ func (m MutationRegistrar) Register()

+ type PercentileAgg struct

+ Compression float64

+ Quantile float64

+ func (a *PercentileAgg) Copy() *PercentileAgg

+ func (a *PercentileAgg) DoFloat(vs *array.Float64)

+ func (a *PercentileAgg) IsNull() bool

+ func (a *PercentileAgg) NewBoolAgg() execute.DoBoolAgg

+ func (a *PercentileAgg) NewFloatAgg() execute.DoFloatAgg

+ func (a *PercentileAgg) NewIntAgg() execute.DoIntAgg

+ func (a *PercentileAgg) NewStringAgg() execute.DoStringAgg

+ func (a *PercentileAgg) NewUIntAgg() execute.DoUIntAgg

+ func (a *PercentileAgg) Type() flux.ColType

+ func (a *PercentileAgg) ValueFloat() float64

+ type PercentileOpSpec struct

+ Compression float64

+ Method string

+ Percentile float64

+ func (s *PercentileOpSpec) Kind() flux.OperationKind

+ type PivotOpSpec struct

+ ColumnKey []string

+ RowKey []string

+ ValueColumn string

+ func (s *PivotOpSpec) Kind() flux.OperationKind

+ type PivotProcedureSpec struct

+ ColumnKey []string

+ RowKey []string

+ ValueColumn string

+ func (s *PivotProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *PivotProcedureSpec) Kind() plan.ProcedureKind

+ type RangeOpSpec struct

+ Start flux.Time

+ StartColumn string

+ Stop flux.Time

+ StopColumn string

+ TimeColumn string

+ func (s *RangeOpSpec) Kind() flux.OperationKind

+ type RangeProcedureSpec struct

+ Bounds flux.Bounds

+ StartColumn string

+ StopColumn string

+ TimeColumn string

+ func (s *RangeProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *RangeProcedureSpec) Kind() plan.ProcedureKind

+ func (s *RangeProcedureSpec) TimeBounds(predecessorBounds *plan.Bounds) *plan.Bounds

+ type RenameMutator struct

+ Columns map[string]string

+ Fn compiler.Func

+ Input values.Object

+ ParamName string

+ func NewRenameMutator(qs flux.OperationSpec) (*RenameMutator, error)

+ func (m *RenameMutator) Mutate(ctx *BuilderContext) error

+ type RenameOpSpec struct

+ Columns map[string]string

+ Fn *semantic.FunctionExpression

+ func (s *RenameOpSpec) Copy() SchemaMutation

+ func (s *RenameOpSpec) Kind() flux.OperationKind

+ func (s *RenameOpSpec) Mutator() (SchemaMutator, error)

+ type SampleOpSpec struct

+ N int64

+ Pos int64

+ func (s *SampleOpSpec) Kind() flux.OperationKind

+ type SampleProcedureSpec struct

+ N int64

+ Pos int64

+ func (s *SampleProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *SampleProcedureSpec) Kind() plan.ProcedureKind

+ type SampleSelector struct

+ N int

+ Pos int

+ func (s *SampleSelector) DoBool(vs *array.Boolean) []int

+ func (s *SampleSelector) DoFloat(vs *array.Float64) []int

+ func (s *SampleSelector) DoInt(vs *array.Int64) []int

+ func (s *SampleSelector) DoString(vs *array.Binary) []int

+ func (s *SampleSelector) DoUInt(vs *array.Uint64) []int

+ func (s *SampleSelector) NewBoolSelector() execute.DoBoolIndexSelector

+ func (s *SampleSelector) NewFloatSelector() execute.DoFloatIndexSelector

+ func (s *SampleSelector) NewIntSelector() execute.DoIntIndexSelector

+ func (s *SampleSelector) NewStringSelector() execute.DoStringIndexSelector

+ func (s *SampleSelector) NewUIntSelector() execute.DoUIntIndexSelector

+ type SchemaMutation interface

+ Copy func() SchemaMutation

+ Mutator func() (SchemaMutator, error)

+ type SchemaMutationProcedureSpec struct

+ Mutations []SchemaMutation

+ func (s *SchemaMutationProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *SchemaMutationProcedureSpec) Kind() plan.ProcedureKind

+ type SchemaMutator interface

+ Mutate func(ctx *BuilderContext) error

+ type SetOpSpec struct

+ Key string

+ Value string

+ func (s *SetOpSpec) Kind() flux.OperationKind

+ type SetProcedureSpec struct

+ Key string

+ Value string

+ func (s *SetProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *SetProcedureSpec) Kind() plan.ProcedureKind

+ type ShiftOpSpec struct

+ Columns []string

+ Shift flux.Duration

+ func (s *ShiftOpSpec) Kind() flux.OperationKind

+ type ShiftProcedureSpec struct

+ Columns []string

+ Now time.Time

+ Shift flux.Duration

+ func (s *ShiftProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *ShiftProcedureSpec) Kind() plan.ProcedureKind

+ func (s *ShiftProcedureSpec) TimeBounds(predecessorBounds *plan.Bounds) *plan.Bounds

+ type SkewAgg struct

+ func (a *SkewAgg) DoFloat(vs *array.Float64)

+ func (a *SkewAgg) DoInt(vs *array.Int64)

+ func (a *SkewAgg) DoUInt(vs *array.Uint64)

+ func (a *SkewAgg) IsNull() bool

+ func (a *SkewAgg) NewBoolAgg() execute.DoBoolAgg

+ func (a *SkewAgg) NewFloatAgg() execute.DoFloatAgg

+ func (a *SkewAgg) NewIntAgg() execute.DoIntAgg

+ func (a *SkewAgg) NewStringAgg() execute.DoStringAgg

+ func (a *SkewAgg) NewUIntAgg() execute.DoUIntAgg

+ func (a *SkewAgg) Type() flux.ColType

+ func (a *SkewAgg) ValueFloat() float64

+ type SkewOpSpec struct

+ func (s *SkewOpSpec) Kind() flux.OperationKind

+ type SkewProcedureSpec struct

+ func (s *SkewProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *SkewProcedureSpec) Kind() plan.ProcedureKind

+ type SortOpSpec struct

+ Columns []string

+ Desc bool

+ func (s *SortOpSpec) Kind() flux.OperationKind

+ type SortProcedureSpec struct

+ Columns []string

+ Desc bool

+ func (s *SortProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *SortProcedureSpec) Kind() plan.ProcedureKind

+ type SpreadAgg struct

+ func (a *SpreadAgg) IsNull() bool

+ func (a *SpreadAgg) NewBoolAgg() execute.DoBoolAgg

+ func (a *SpreadAgg) NewFloatAgg() execute.DoFloatAgg

+ func (a *SpreadAgg) NewIntAgg() execute.DoIntAgg

+ func (a *SpreadAgg) NewStringAgg() execute.DoStringAgg

+ func (a *SpreadAgg) NewUIntAgg() execute.DoUIntAgg

+ type SpreadFloatAgg struct

+ func (a *SpreadFloatAgg) DoFloat(vs *array.Float64)

+ func (a *SpreadFloatAgg) Type() flux.ColType

+ func (a *SpreadFloatAgg) ValueFloat() float64

+ type SpreadIntAgg struct

+ func (a *SpreadIntAgg) DoInt(vs *array.Int64)

+ func (a *SpreadIntAgg) Type() flux.ColType

+ func (a *SpreadIntAgg) ValueInt() int64

+ type SpreadOpSpec struct

+ func (s *SpreadOpSpec) Kind() flux.OperationKind

+ type SpreadProcedureSpec struct

+ func (s *SpreadProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *SpreadProcedureSpec) Kind() plan.ProcedureKind

+ type SpreadUIntAgg struct

+ func (a *SpreadUIntAgg) DoUInt(vs *array.Uint64)

+ func (a *SpreadUIntAgg) Type() flux.ColType

+ func (a *SpreadUIntAgg) ValueUInt() uint64

+ type StateTrackingOpSpec struct

+ CountColumn string

+ DurationColumn string

+ DurationUnit flux.Duration

+ Fn *semantic.FunctionExpression

+ TimeColumn string

+ func (s *StateTrackingOpSpec) Kind() flux.OperationKind

+ type StateTrackingProcedureSpec struct

+ CountColumn string

+ DurationColumn string

+ DurationUnit flux.Duration

+ Fn *semantic.FunctionExpression

+ TimeCol string

+ func (s *StateTrackingProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *StateTrackingProcedureSpec) Kind() plan.ProcedureKind

+ type StddevAgg struct

+ func (a *StddevAgg) DoFloat(vs *array.Float64)

+ func (a *StddevAgg) DoInt(vs *array.Int64)

+ func (a *StddevAgg) DoUInt(vs *array.Uint64)

+ func (a *StddevAgg) IsNull() bool

+ func (a *StddevAgg) NewBoolAgg() execute.DoBoolAgg

+ func (a *StddevAgg) NewFloatAgg() execute.DoFloatAgg

+ func (a *StddevAgg) NewIntAgg() execute.DoIntAgg

+ func (a *StddevAgg) NewStringAgg() execute.DoStringAgg

+ func (a *StddevAgg) NewUIntAgg() execute.DoUIntAgg

+ func (a *StddevAgg) Type() flux.ColType

+ func (a *StddevAgg) ValueFloat() float64

+ type StddevOpSpec struct

+ func (s *StddevOpSpec) Kind() flux.OperationKind

+ type StddevProcedureSpec struct

+ func (s *StddevProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *StddevProcedureSpec) Kind() plan.ProcedureKind

+ type SumAgg struct

+ func (a *SumAgg) NewBoolAgg() execute.DoBoolAgg

+ func (a *SumAgg) NewFloatAgg() execute.DoFloatAgg

+ func (a *SumAgg) NewIntAgg() execute.DoIntAgg

+ func (a *SumAgg) NewStringAgg() execute.DoStringAgg

+ func (a *SumAgg) NewUIntAgg() execute.DoUIntAgg

+ type SumFloatAgg struct

+ func (a *SumFloatAgg) DoFloat(vs *array.Float64)

+ func (a *SumFloatAgg) IsNull() bool

+ func (a *SumFloatAgg) Type() flux.ColType

+ func (a *SumFloatAgg) ValueFloat() float64

+ type SumIntAgg struct

+ func (a *SumIntAgg) DoInt(vs *array.Int64)

+ func (a *SumIntAgg) IsNull() bool

+ func (a *SumIntAgg) Type() flux.ColType

+ func (a *SumIntAgg) ValueInt() int64

+ type SumOpSpec struct

+ func (s *SumOpSpec) Kind() flux.OperationKind

+ type SumProcedureSpec struct

+ func (s *SumProcedureSpec) AggregateMethod() string

+ func (s *SumProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *SumProcedureSpec) Kind() plan.ProcedureKind

+ func (s *SumProcedureSpec) ReAggregateSpec() plan.ProcedureSpec

+ type SumUIntAgg struct

+ func (a *SumUIntAgg) DoUInt(vs *array.Uint64)

+ func (a *SumUIntAgg) IsNull() bool

+ func (a *SumUIntAgg) Type() flux.ColType

+ func (a *SumUIntAgg) ValueUInt() uint64

+ type TDigestPercentileProcedureSpec struct

+ Compression float64

+ Percentile float64

+ func (s *TDigestPercentileProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *TDigestPercentileProcedureSpec) Kind() plan.ProcedureKind

+ type UnionOpSpec struct

+ func (s *UnionOpSpec) Kind() flux.OperationKind

+ type UnionProcedureSpec struct

+ func (s *UnionProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *UnionProcedureSpec) Kind() plan.ProcedureKind

+ type UniqueOpSpec struct

+ Column string

+ func (s *UniqueOpSpec) Kind() flux.OperationKind

+ type UniqueProcedureSpec struct

+ Column string

+ func (s *UniqueProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *UniqueProcedureSpec) Kind() plan.ProcedureKind

+ type WindowOpSpec struct

+ CreateEmpty bool

+ Every flux.Duration

+ Period flux.Duration

+ Round flux.Duration

+ Start flux.Time

+ StartColumn string

+ StopColumn string

+ TimeColumn string

+ Triggering flux.TriggerSpec

+ func (s *WindowOpSpec) Kind() flux.OperationKind

+ type WindowProcedureSpec struct

+ CreateEmpty bool

+ StartColumn string

+ StopColumn string

+ TimeColumn string

+ Triggering flux.TriggerSpec

+ Window plan.WindowSpec

+ func (s *WindowProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *WindowProcedureSpec) Kind() plan.ProcedureKind

+ func (s *WindowProcedureSpec) TriggerSpec() flux.TriggerSpec

+ type YieldOpSpec struct

+ Name string

+ func (s *YieldOpSpec) Kind() flux.OperationKind

+ type YieldProcedureSpec struct

+ Name string

+ func (s *YieldProcedureSpec) Copy() plan.ProcedureSpec

+ func (s *YieldProcedureSpec) Kind() plan.ProcedureKind

+ func (s *YieldProcedureSpec) YieldName() string