Versions in this module Expand all Collapse all v0 v0.195.1 Sep 17, 2023 v0.195.0 Sep 13, 2023 v0.194.3 Jun 11, 2023 Changes in this version + const AggregateWindowKind + const ChandeMomentumOscillatorKind + const ColumnsKind + const CountKind + const CovarianceKind + const CumulativeSumKind + const DefaultUpperBoundColumnLabel + const DerivativeKind + const DieKind + const DifferenceKind + const DistinctKind + const DropKind + const DuplicateKind + const ElapsedKind + const ExactQuantileAggKind + const ExactQuantileSelectKind + const ExponentialMovingAverageKind + const FillKind + const FilterKind + const FirstKind + const GroupKind + const HistogramKind + const HistogramQuantileKind + const HoltWintersKind + const HourSelectionKind + 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 ModeKind + const MovingAverageKind + const ParallelMergeKind + const PivotKind + const QuantileKind + const RangeKind + const ReduceKind + const RelativeStrengthIndexKind + const RenameKind + const SampleKind + const SchemaMutationKind + const SetKind + const ShiftKind + const SkewKind + const SortKind + const SortLimitKind + const SortedPivotKind + const SpreadKind + const StateTrackingKind + const StddevKind + const SumKind + const TailKind + const TripleExponentialDerivativeKind + const UnionKind + const UniqueKind + const WindowKind + const YieldKind + var Registrars = []MutationRegistrar + var SchemaMutationOps = []flux.OperationKind + func CreateColumnsOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error) + func CreateCountOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error) + 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 CreateHistogramQuantileOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error) + func CreateIntegralOpSpec(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 CreateMeanOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error) + func CreateMinOpSpec(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 CreateUniqueOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error) + func CreateWindowOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error) + func CreatekamaOpSpec(args flux.Arguments, a *flux.Administration) (flux.OperationSpec, error) + func Die() values.Function + func MakeContainsFunc() values.Function + func MakeLengthFunc() values.Function + func NewChandeMomentumOscillatorTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *chandeMomentumOscillatorTransformation + func NewColumnsTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *ColumnsProcedureSpec) *columnsTransformation + func NewCumulativeSumTransformation(id execute.DatasetID, spec *CumulativeSumProcedureSpec, mem memory.Allocator) (execute.Transformation, execute.Dataset, error) + func NewDerivativeTransformation(ctx context.Context, id execute.DatasetID, spec *DerivativeProcedureSpec, ...) (execute.Transformation, execute.Dataset, error) + func NewDifferenceTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *differenceTransformation + func NewDistinctTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *distinctTransformation + func NewElapsedTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *ElapsedProcedureSpec) *elapsedTransformation + func NewExponentialMovingAverageTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *exponentialMovingAverageTransformation + func NewFillTransformation(ctx context.Context, spec *FillProcedureSpec, id execute.DatasetID, ...) (execute.Transformation, execute.Dataset) + func NewFilterTransformation(ctx context.Context, spec *FilterProcedureSpec, id execute.DatasetID, ...) (execute.Transformation, execute.Dataset, error) + func NewFindColumnFunction() values.Value + func NewFindRecordFunction() values.Value + func NewFixedWindowTransformation(ctx context.Context, d execute.Dataset, cache execute.TableBuilderCache, ...) execute.Transformation + func NewGetColumnFunction() values.Value + func NewGetRecordFunction() values.Value + func NewGroupTransformation(ctx context.Context, spec *GroupProcedureSpec, id execute.DatasetID, ...) (execute.Transformation, execute.Dataset, error) + func NewHistogramTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *histogramTransformation + func NewHistorgramQuantileTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) execute.Transformation + func NewHoltWintersTransformation(d execute.Dataset, cache execute.TableBuilderCache, alloc memory.Allocator, ...) *holtWintersTransformation + func NewHourSelectionTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *hourSelectionTransformation + 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(spec *LimitProcedureSpec, id execute.DatasetID, mem memory.Allocator) (execute.Transformation, execute.Dataset, error) + func NewMergeJoinTransformation(d execute.Dataset, cache *MergeJoinCache, spec *MergeJoinProcedureSpec, ...) *mergeJoinTransformation + func NewModeTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *ModeProcedureSpec) *modeTransformation + func NewMovingAverageTransformation(id execute.DatasetID, spec *MovingAverageProcedureSpec, mem memory.Allocator) (execute.Transformation, execute.Dataset, error) + func NewNarrowDifferenceTransformation(spec *DifferenceProcedureSpec, id execute.DatasetID, alloc memory.Allocator) (execute.Transformation, execute.Dataset, error) + func NewNarrowFillTransformation(ctx context.Context, spec *FillProcedureSpec, id execute.DatasetID, ...) (execute.Transformation, execute.Dataset, error) + func NewPivotTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *PivotProcedureSpec) *pivotTransformation + func NewRangeTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *RangeProcedureSpec, ...) (*rangeTransformation, error) + func NewReduceTransformation(ctx context.Context, spec *ReduceProcedureSpec, d execute.Dataset, ...) (*reduceTransformation, error) + func NewRelativeStrengthIndexTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *relativeStrengthIndexTransformation + func NewSchemaMutationTransformation(ctx context.Context, spec *SchemaMutationProcedureSpec, id execute.DatasetID, ...) (execute.Transformation, execute.Dataset, error) + func NewSetTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *SetProcedureSpec) execute.Transformation + func NewShiftTransformation(id execute.DatasetID, spec *ShiftProcedureSpec, mem memory.Allocator) (execute.Transformation, execute.Dataset, error) + func NewSortLimitTransformation(id execute.DatasetID, spec *SortLimitProcedureSpec, mem memory.Allocator) (execute.Transformation, execute.Dataset, error) + func NewSortTransformation(id execute.DatasetID, spec *SortProcedureSpec, mem memory.Allocator) (execute.Transformation, execute.Dataset, error) + func NewStateTrackingTransformation(ctx context.Context, spec *StateTrackingProcedureSpec, id execute.DatasetID, ...) (execute.Transformation, execute.Dataset, error) + func NewTableFindFunction() values.Value + func NewTailTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *TailProcedureSpec) *tailTransformation + func NewTripleExponentialDerivativeTransformation(d execute.Dataset, cache execute.TableBuilderCache, alloc memory.Allocator, ...) *tripleExponentialDerivativeTransformation + func NewUnionTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *UnionProcedureSpec, ...) *unionTransformation + func NewUniqueTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *UniqueProcedureSpec) *uniqueTransformation + func NewkamaTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *KamaProcedureSpec) *kamaTransformation + func UseDeprecatedImpl(spec plan.ProcedureSpec) + 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 + AggregateKind plan.ProcedureKind + ForceAggregate bool + ParallelMergeFactor int + UseStart bool + ValueCol string + WindowSpec *WindowProcedureSpec + func (s *AggregateWindowProcedureSpec) Copy() plan.ProcedureSpec + func (s *AggregateWindowProcedureSpec) Kind() plan.ProcedureKind + func (s *AggregateWindowProcedureSpec) OutputAttributes() plan.PhysicalAttributes + func (s *AggregateWindowProcedureSpec) RequiredAttributes() []plan.PhysicalAttributes + 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 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 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 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.Float) + func (a *CountAgg) DoInt(vs *array.Int) + func (a *CountAgg) DoString(vs *array.String) + func (a *CountAgg) DoUInt(vs *array.Uint) + 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 + func (s *CountProcedureSpec) TriggerSpec() plan.TriggerSpec + type CovarianceOpSpec struct + Columns []string + PearsonCorrelation bool + ValueDst string + func (s *CovarianceOpSpec) Kind() flux.OperationKind + type CovarianceProcedureSpec struct + Columns []string + PearsonCorrelation bool + ValueLabel string + func (s *CovarianceProcedureSpec) Copy() plan.ProcedureSpec + func (s *CovarianceProcedureSpec) Kind() plan.ProcedureKind + func (s *CovarianceProcedureSpec) TriggerSpec() plan.TriggerSpec + type CovarianceTransformation struct + func NewCovarianceTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *CovarianceTransformation + func (t *CovarianceTransformation) DoFloat(xs, ys *array.Float) + 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 + func (s *CumulativeSumProcedureSpec) TriggerSpec() plan.TriggerSpec + type DerivativeOpSpec struct + Columns []string + InitialZero bool + NonNegative bool + TimeColumn string + Unit flux.Duration + func (s *DerivativeOpSpec) Kind() flux.OperationKind + type DerivativeProcedureSpec struct + Columns []string + InitialZero bool + NonNegative bool + TimeColumn string + Unit flux.Duration + func (s *DerivativeProcedureSpec) Copy() plan.ProcedureSpec + func (s *DerivativeProcedureSpec) Kind() plan.ProcedureKind + func (s *DerivativeProcedureSpec) TriggerSpec() plan.TriggerSpec + type DifferenceOpSpec struct + Columns []string + InitialZero bool + KeepFirst bool + NonNegative bool + func (s *DifferenceOpSpec) Kind() flux.OperationKind + type DifferenceProcedureSpec struct + Columns []string + InitialZero bool + KeepFirst bool + NonNegative bool + func (s *DifferenceProcedureSpec) Copy() plan.ProcedureSpec + func (s *DifferenceProcedureSpec) Kind() plan.ProcedureKind + func (s *DifferenceProcedureSpec) TriggerSpec() plan.TriggerSpec + 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 + func (s *DistinctProcedureSpec) TriggerSpec() plan.TriggerSpec + type DropKeepMutator struct + DropCols map[string]bool + FlipPredicate bool + KeepCols map[string]bool + func NewDropMutator(ctx context.Context, s *DropOpSpec) (*DropKeepMutator, error) + func NewKeepMutator(ctx context.Context, s *KeepOpSpec) (*DropKeepMutator, error) + func (m *DropKeepMutator) Mutate(ctx context.Context, bctx *BuilderContext) error + type DropOpSpec struct + Columns []string + Predicate interpreter.ResolvedFunction + func (s *DropOpSpec) Copy() SchemaMutation + func (s *DropOpSpec) Kind() flux.OperationKind + func (s *DropOpSpec) Mutator(ctx context.Context) (SchemaMutator, error) + type DualImplProcedureSpec struct + UseDeprecated bool + func (s *DualImplProcedureSpec) Copy() plan.ProcedureSpec + func (s *DualImplProcedureSpec) Kind() plan.ProcedureKind + func (s *DualImplProcedureSpec) PlanDetails() string + type DuplicateMutator struct + As string + Column string + func NewDuplicateMutator(qs flux.OperationSpec) (*DuplicateMutator, error) + func (m *DuplicateMutator) Mutate(ctx context.Context, bctx *BuilderContext) error + type DuplicateOpSpec struct + As string + Column string + func (s *DuplicateOpSpec) Copy() SchemaMutation + func (s *DuplicateOpSpec) Kind() flux.OperationKind + func (s *DuplicateOpSpec) Mutator(ctx context.Context) (SchemaMutator, error) + 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 ExactQuantileAgg struct + Quantile float64 + func (a *ExactQuantileAgg) Copy() *ExactQuantileAgg + func (a *ExactQuantileAgg) DoFloat(vs *array.Float) + 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 ExponentialMovingAverageOpSpec struct + N int64 + func (s *ExponentialMovingAverageOpSpec) Kind() flux.OperationKind + type ExponentialMovingAverageProcedureSpec struct + N int64 + func (s *ExponentialMovingAverageProcedureSpec) Copy() plan.ProcedureSpec + func (s *ExponentialMovingAverageProcedureSpec) Kind() plan.ProcedureKind + func (s *ExponentialMovingAverageProcedureSpec) TriggerSpec() plan.TriggerSpec + 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 interpreter.ResolvedFunction + OnEmpty string + func (s *FilterOpSpec) Kind() flux.OperationKind + type FilterProcedureSpec struct + Fn interpreter.ResolvedFunction + KeepEmptyTables bool + func (s *FilterProcedureSpec) Copy() plan.ProcedureSpec + func (s *FilterProcedureSpec) Kind() plan.ProcedureKind + func (s *FilterProcedureSpec) PassThroughAttribute(attrKey string) bool + func (s *FilterProcedureSpec) PlanDetails() string + func (s *FilterProcedureSpec) TriggerSpec() plan.TriggerSpec + type FirstOpSpec struct + func (s *FirstOpSpec) Kind() flux.OperationKind + type FirstProcedureSpec struct + func (s *FirstProcedureSpec) Copy() plan.ProcedureSpec + func (s *FirstProcedureSpec) Kind() plan.ProcedureKind + func (s *FirstProcedureSpec) TriggerSpec() plan.TriggerSpec + type FirstSelector struct + func (s *FirstSelector) DoBool(vs *array.Boolean) []int + func (s *FirstSelector) DoFloat(vs *array.Float) []int + func (s *FirstSelector) DoInt(vs *array.Int) []int + func (s *FirstSelector) DoString(vs *array.String) []int + func (s *FirstSelector) DoTime(vs *array.Int) []int + func (s *FirstSelector) DoUInt(vs *array.Uint) []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) NewTimeSelector() execute.DoTimeIndexSelector + 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 + func (s *GroupProcedureSpec) PassThroughAttribute(attrKey string) bool + 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 + OnNonmonotonic string + Quantile float64 + UpperBoundColumn string + ValueColumn string + func (s *HistogramQuantileOpSpec) Kind() flux.OperationKind + type HistogramQuantileProcedureSpec struct + CountColumn string + MinValue float64 + OnNonmonotonic string + Quantile float64 + UpperBoundColumn string + ValueColumn string + func (s *HistogramQuantileProcedureSpec) Copy() plan.ProcedureSpec + func (s *HistogramQuantileProcedureSpec) Kind() plan.ProcedureKind + type HoltWintersOpSpec struct + Column string + Interval flux.Duration + N int64 + S int64 + TimeColumn string + WithFit bool + WithMinSSE bool + func (s *HoltWintersOpSpec) Kind() flux.OperationKind + type HoltWintersProcedureSpec struct + Column string + Interval flux.Duration + N int64 + S int64 + TimeColumn string + WithFit bool + WithMinSSE bool + func (s *HoltWintersProcedureSpec) Copy() plan.ProcedureSpec + func (s *HoltWintersProcedureSpec) Kind() plan.ProcedureKind + func (s *HoltWintersProcedureSpec) TriggerSpec() plan.TriggerSpec + type HourSelectionOpSpec struct + Location string + Offset values.Duration + Start int64 + Stop int64 + TimeColumn string + func (s *HourSelectionOpSpec) Kind() flux.OperationKind + type HourSelectionProcedureSpec struct + Location string + Offset values.Duration + 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 IntegralOpSpec struct + Interpolate string + TimeColumn string + Unit flux.Duration + func (s *IntegralOpSpec) Kind() flux.OperationKind + type IntegralProcedureSpec struct + Interpolate bool + TimeColumn string + Unit flux.Duration + func (s *IntegralProcedureSpec) Copy() plan.ProcedureSpec + func (s *IntegralProcedureSpec) Kind() plan.ProcedureKind + func (s *IntegralProcedureSpec) TriggerSpec() plan.TriggerSpec + type JoinOpSpec struct + Method string + On []string + func (s *JoinOpSpec) Kind() flux.OperationKind + 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 KeepOpSpec struct + Columns []string + Predicate interpreter.ResolvedFunction + func (s *KeepOpSpec) Copy() SchemaMutation + func (s *KeepOpSpec) Kind() flux.OperationKind + func (s *KeepOpSpec) Mutator(ctx context.Context) (SchemaMutator, error) + type KeyValuesOpSpec struct + KeyColumns []string + PredicateFn interpreter.ResolvedFunction + func (s *KeyValuesOpSpec) Kind() flux.OperationKind + type KeyValuesProcedureSpec struct + KeyColumns []string + Predicate interpreter.ResolvedFunction + func (s *KeyValuesProcedureSpec) Copy() plan.ProcedureSpec + func (s *KeyValuesProcedureSpec) Kind() plan.ProcedureKind + func (s *KeyValuesProcedureSpec) TriggerSpec() plan.TriggerSpec + 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 + func (s *KeysProcedureSpec) TriggerSpec() plan.TriggerSpec + type LastOpSpec struct + func (s *LastOpSpec) Kind() flux.OperationKind + type LastProcedureSpec struct + func (s *LastProcedureSpec) Copy() plan.ProcedureSpec + func (s *LastProcedureSpec) Kind() plan.ProcedureKind + func (s *LastProcedureSpec) TriggerSpec() plan.TriggerSpec + type LastSelector struct + func (s *LastSelector) DoBool(vs *array.Boolean, cr flux.ColReader) + func (s *LastSelector) DoFloat(vs *array.Float, cr flux.ColReader) + func (s *LastSelector) DoInt(vs *array.Int, cr flux.ColReader) + func (s *LastSelector) DoString(vs *array.String, cr flux.ColReader) + func (s *LastSelector) DoTime(vs *array.Int, cr flux.ColReader) + func (s *LastSelector) DoUInt(vs *array.Uint, 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) NewTimeSelector() execute.DoTimeRowSelector + 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 + func (s *LimitProcedureSpec) TriggerSpec() plan.TriggerSpec + type MapOpSpec struct + Fn interpreter.ResolvedFunction + MergeKey bool + func (s *MapOpSpec) Kind() flux.OperationKind + type MapProcedureSpec struct + Fn interpreter.ResolvedFunction + MergeKey bool + func (s *MapProcedureSpec) Copy() plan.ProcedureSpec + func (s *MapProcedureSpec) Kind() plan.ProcedureKind + type MaxFloatSelector struct + func (s *MaxFloatSelector) DoFloat(vs *array.Float, cr flux.ColReader) + type MaxIntSelector struct + func (s *MaxIntSelector) DoInt(vs *array.Int, 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 + func (s *MaxProcedureSpec) TriggerSpec() plan.TriggerSpec + 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) NewTimeSelector() execute.DoTimeRowSelector + func (s *MaxSelector) NewUIntSelector() execute.DoUIntRowSelector + func (s *MaxSelector) Rows() []execute.Row + type MaxTimeSelector struct + func (s *MaxTimeSelector) DoTime(vs *array.Int, cr flux.ColReader) + type MaxUIntSelector struct + func (s *MaxUIntSelector) DoUInt(vs *array.Uint, cr flux.ColReader) + type MeanAgg struct + func (a *MeanAgg) DoFloat(vs *array.Float) + func (a *MeanAgg) DoInt(vs *array.Int) + func (a *MeanAgg) DoUInt(vs *array.Uint) + 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 + func (s *MeanProcedureSpec) TriggerSpec() plan.TriggerSpec + 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) + type MergeGroupRule struct + func (r MergeGroupRule) Name() string + func (r MergeGroupRule) Pattern() plan.Pattern + func (r MergeGroupRule) Rewrite(ctx context.Context, lastGroup plan.Node) (plan.Node, 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) error) error + func (c *MergeJoinCache) ForEachWithContext(f func(flux.GroupKey, execute.Trigger, execute.TableContext) error) error + func (c *MergeJoinCache) SetTriggerSpec(spec plan.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.Float, cr flux.ColReader) + type MinIntSelector struct + func (s *MinIntSelector) DoInt(vs *array.Int, 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 + func (s *MinProcedureSpec) TriggerSpec() plan.TriggerSpec + 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) NewTimeSelector() execute.DoTimeRowSelector + func (s *MinSelector) NewUIntSelector() execute.DoUIntRowSelector + func (s *MinSelector) Rows() []execute.Row + type MinTimeSelector struct + func (s *MinTimeSelector) DoTime(vs *array.Int, cr flux.ColReader) + type MinUIntSelector struct + func (s *MinUIntSelector) DoUInt(vs *array.Uint, cr flux.ColReader) + 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 + N int64 + func (s *MovingAverageOpSpec) Kind() flux.OperationKind + type MovingAverageProcedureSpec struct + N int64 + func (s *MovingAverageProcedureSpec) Copy() plan.ProcedureSpec + func (s *MovingAverageProcedureSpec) Kind() plan.ProcedureKind + func (s *MovingAverageProcedureSpec) TriggerSpec() plan.TriggerSpec + type MutationRegistrar struct + Create flux.CreateOperationSpec + Kind flux.OperationKind + Type semantic.MonoType + func (m MutationRegistrar) Register() + 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 PartitionMergeProcedureSpec struct + Factor int + func (o *PartitionMergeProcedureSpec) Copy() plan.ProcedureSpec + func (o *PartitionMergeProcedureSpec) Kind() plan.ProcedureKind + func (o *PartitionMergeProcedureSpec) OutputAttributes() plan.PhysicalAttributes + func (o *PartitionMergeProcedureSpec) RequiredAttributes() []plan.PhysicalAttributes + 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 PivotOpSpec struct + ColumnKey []string + RowKey []string + ValueColumn string + func (s *PivotOpSpec) Kind() flux.OperationKind + type PivotProcedureSpec struct + ColumnKey []string + IsKeyColumnFunc func(label string) bool + IsSortedByFunc func(cols []string, desc bool) bool + RowKey []string + ValueColumn string + func (s *PivotProcedureSpec) Copy() plan.ProcedureSpec + func (s *PivotProcedureSpec) Kind() plan.ProcedureKind + type QuantileAgg struct + Compression float64 + Quantile float64 + func NewQuantileAgg(q, comp float64, mem memory.Allocator, size int) *QuantileAgg + func (a *QuantileAgg) Close() error + 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 + type QuantileAggState struct + func (s *QuantileAggState) Close() error + func (s *QuantileAggState) DoFloat(vs *array.Float) + func (s *QuantileAggState) DoInt(vs *array.Int) + func (s *QuantileAggState) DoUInt(vs *array.Uint) + func (s *QuantileAggState) IsNull() bool + func (s *QuantileAggState) Type() flux.ColType + func (s *QuantileAggState) ValueFloat() float64 + type QuantileOpSpec struct + Compression float64 + Method string + Quantile float64 + func (s *QuantileOpSpec) Kind() flux.OperationKind + 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) PassThroughAttribute(attrKey string) bool + func (s *RangeProcedureSpec) TimeBounds(predecessorBounds *plan.Bounds) *plan.Bounds + func (s *RangeProcedureSpec) TriggerSpec() plan.TriggerSpec + type ReduceOpSpec struct + Fn interpreter.ResolvedFunction + Identity values.Object + func (s *ReduceOpSpec) Kind() flux.OperationKind + type ReduceProcedureSpec struct + Fn interpreter.ResolvedFunction + Identity values.Object + func (s *ReduceProcedureSpec) Copy() plan.ProcedureSpec + func (s *ReduceProcedureSpec) Kind() plan.ProcedureKind + 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 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 RemoveTrivialFilterRule struct + func (RemoveTrivialFilterRule) Name() string + func (RemoveTrivialFilterRule) Pattern() plan.Pattern + func (RemoveTrivialFilterRule) Rewrite(ctx context.Context, filterNode plan.Node) (plan.Node, bool, error) + type RenameMutator struct + Columns map[string]string + func NewRenameMutator(ctx context.Context, qs flux.OperationSpec) (*RenameMutator, error) + func (m *RenameMutator) Mutate(ctx context.Context, bctx *BuilderContext) error + type RenameOpSpec struct + Columns map[string]string + Fn interpreter.ResolvedFunction + func (s *RenameOpSpec) Copy() SchemaMutation + func (s *RenameOpSpec) Kind() flux.OperationKind + func (s *RenameOpSpec) Mutator(ctx context.Context) (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 + func (s *SampleProcedureSpec) TriggerSpec() plan.TriggerSpec + type SampleSelector struct + N int + Pos int + func (s *SampleSelector) DoBool(vs *array.Boolean) []int + func (s *SampleSelector) DoFloat(vs *array.Float) []int + func (s *SampleSelector) DoInt(vs *array.Int) []int + func (s *SampleSelector) DoString(vs *array.String) []int + func (s *SampleSelector) DoTime(vs *array.Int) []int + func (s *SampleSelector) DoUInt(vs *array.Uint) []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) NewTimeSelector() execute.DoTimeIndexSelector + func (s *SampleSelector) NewUIntSelector() execute.DoUIntIndexSelector + type SchemaMutation interface + Copy func() SchemaMutation + Mutator func(ctx context.Context) (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 context.Context, bctx *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 + func (s *ShiftProcedureSpec) TriggerSpec() plan.TriggerSpec + type SkewAgg struct + func (a *SkewAgg) DoFloat(vs *array.Float) + func (a *SkewAgg) DoInt(vs *array.Int) + func (a *SkewAgg) DoUInt(vs *array.Uint) + 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 + func (s *SkewProcedureSpec) TriggerSpec() plan.TriggerSpec + 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) + 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 + func (s *SortProcedureSpec) OutputAttributes() plan.PhysicalAttributes + func (s *SortProcedureSpec) TriggerSpec() plan.TriggerSpec + type SortedPivotProcedureSpec struct + ColumnKey []string + RowKey []string + ValueColumn string + func (s *SortedPivotProcedureSpec) Copy() plan.ProcedureSpec + func (s *SortedPivotProcedureSpec) Kind() plan.ProcedureKind + func (s *SortedPivotProcedureSpec) OutputAttributes() plan.PhysicalAttributes + 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.Float) + func (a *SpreadFloatAgg) Type() flux.ColType + func (a *SpreadFloatAgg) ValueFloat() float64 + type SpreadIntAgg struct + func (a *SpreadIntAgg) DoInt(vs *array.Int) + 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 + func (s *SpreadProcedureSpec) TriggerSpec() plan.TriggerSpec + type SpreadUIntAgg struct + func (a *SpreadUIntAgg) DoUInt(vs *array.Uint) + func (a *SpreadUIntAgg) Type() flux.ColType + func (a *SpreadUIntAgg) ValueUInt() uint64 + type StateTrackingOpSpec struct + CountColumn string + DurationColumn string + DurationUnit flux.Duration + Fn interpreter.ResolvedFunction + TimeColumn string + func (s *StateTrackingOpSpec) Kind() flux.OperationKind + type StateTrackingProcedureSpec struct + CountColumn string + DurationColumn string + DurationUnit flux.Duration + Fn interpreter.ResolvedFunction + TimeCol string + func (s *StateTrackingProcedureSpec) Copy() plan.ProcedureSpec + func (s *StateTrackingProcedureSpec) Kind() plan.ProcedureKind + func (s *StateTrackingProcedureSpec) TriggerSpec() plan.TriggerSpec + type StddevAgg struct + Mode string + func (a *StddevAgg) DoFloat(vs *array.Float) + func (a *StddevAgg) DoInt(vs *array.Int) + func (a *StddevAgg) DoUInt(vs *array.Uint) + 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 + Mode string + func (s *StddevOpSpec) Kind() flux.OperationKind + type StddevProcedureSpec struct + Mode string + func (s *StddevProcedureSpec) Copy() plan.ProcedureSpec + func (s *StddevProcedureSpec) Kind() plan.ProcedureKind + func (s *StddevProcedureSpec) TriggerSpec() plan.TriggerSpec + 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.Float) + 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.Int) + 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 + func (s *SumProcedureSpec) TriggerSpec() plan.TriggerSpec + type SumUIntAgg struct + func (a *SumUIntAgg) DoUInt(vs *array.Uint) + func (a *SumUIntAgg) IsNull() bool + func (a *SumUIntAgg) Type() flux.ColType + func (a *SumUIntAgg) ValueUInt() uint64 + 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 + 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 + 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 + 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 + func (s *UniqueProcedureSpec) TriggerSpec() plan.TriggerSpec + type WindowOpSpec struct + CreateEmpty bool + Every flux.Duration + Location plan.Location + Offset flux.Duration + Period flux.Duration + StartColumn string + StopColumn string + TimeColumn string + func (s *WindowOpSpec) Kind() flux.OperationKind + type WindowProcedureSpec struct + CreateEmpty bool + Optimize bool + StartColumn string + StopColumn string + TimeColumn string + Window plan.WindowSpec + func (s *WindowProcedureSpec) Copy() plan.ProcedureSpec + func (s *WindowProcedureSpec) Kind() plan.ProcedureKind + type WindowTriggerPhysicalRule struct + func (WindowTriggerPhysicalRule) Name() string + func (WindowTriggerPhysicalRule) Pattern() plan.Pattern + func (WindowTriggerPhysicalRule) Rewrite(ctx context.Context, window plan.Node) (plan.Node, bool, error) + 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
Go to main page