Versions in this module Expand all Collapse all v0 v0.13.0 Jan 7, 2019 v0.12.0 Jan 2, 2019 v0.11.0 Dec 18, 2018 v0.10.0 Dec 17, 2018 Changes in this version type StateTrackingOpSpec + CountColumn string + DurationColumn string type StateTrackingProcedureSpec + CountColumn string + DurationColumn string v0.9.0 Dec 12, 2018 v0.8.0 Dec 11, 2018 Changes in this version + const AssertEqualsKind + type AssertEqualsOpSpec struct + Name string + func (s *AssertEqualsOpSpec) Kind() flux.OperationKind + type AssertEqualsProcedureSpec struct + Name string + func (s *AssertEqualsProcedureSpec) Copy() plan.ProcedureSpec + func (s *AssertEqualsProcedureSpec) Kind() plan.ProcedureKind + type AssertEqualsTransformation struct + func NewAssertEqualsTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *AssertEqualsTransformation + func (t *AssertEqualsTransformation) Finish(id execute.DatasetID, err error) + func (t *AssertEqualsTransformation) Process(id execute.DatasetID, tbl flux.Table) error + func (t *AssertEqualsTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error + func (t *AssertEqualsTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error + func (t *AssertEqualsTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error + 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) v0.7.4 Dec 4, 2018 v0.7.3 Dec 4, 2018 v0.7.2 Dec 4, 2018 Changes in this version type GroupOpSpec + Columns []string + Mode string v0.7.1 Nov 28, 2018 Changes in this version type HistogramOpSpec + Bins []float64 v0.7.0 Nov 6, 2018 Changes in this version + const CountKind + const CovarianceKind + const CumulativeSumKind + const DefaultUpperBoundColumnLabel + const DerivativeKind + const DifferenceKind + const DistinctKind + const DropKind + const DuplicateKind + const ExactPercentileAggKind + const ExactPercentileSelectKind + 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 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 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 + func SystemTime() values.Value + 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 CountAgg struct + func (a *CountAgg) DoBool(vs []bool) + func (a *CountAgg) DoFloat(vs []float64) + func (a *CountAgg) DoInt(vs []int64) + func (a *CountAgg) DoString(vs []string) + func (a *CountAgg) DoUInt(vs []uint64) + 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 []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 []float64) + 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 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 []bool) []int + func (s *FirstSelector) DoFloat(vs []float64) []int + func (s *FirstSelector) DoInt(vs []int64) []int + func (s *FirstSelector) DoString(vs []string) []int + func (s *FirstSelector) DoUInt(vs []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 + All bool + By []string + Except []string + None bool + func (s *GroupOpSpec) Kind() flux.OperationKind + type GroupProcedureSpec struct + GroupKeys []string + GroupMode functions.GroupMode + func (s *GroupProcedureSpec) Copy() plan.ProcedureSpec + func (s *GroupProcedureSpec) Kind() plan.ProcedureKind + type HistogramOpSpec struct + Buckets []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 + Except []string + func (s *KeysOpSpec) Kind() flux.OperationKind + type KeysProcedureSpec struct + Except []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 []bool, cr flux.ColReader) + func (s *LastSelector) DoFloat(vs []float64, cr flux.ColReader) + func (s *LastSelector) DoInt(vs []int64, cr flux.ColReader) + func (s *LastSelector) DoString(vs []string, cr flux.ColReader) + func (s *LastSelector) DoUInt(vs []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 []float64, cr flux.ColReader) + type MaxIntSelector struct + func (s *MaxIntSelector) DoInt(vs []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 []uint64, cr flux.ColReader) + type MeanAgg struct + func (a *MeanAgg) DoFloat(vs []float64) + func (a *MeanAgg) DoInt(vs []int64) + func (a *MeanAgg) DoUInt(vs []uint64) + 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 MergeJoinCache struct + func NewMergeJoinCache(alloc *execute.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 []float64, cr flux.ColReader) + type MinIntSelector struct + func (s *MinIntSelector) DoInt(vs []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 []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 []float64) + 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 []bool) []int + func (s *SampleSelector) DoFloat(vs []float64) []int + func (s *SampleSelector) DoInt(vs []int64) []int + func (s *SampleSelector) DoString(vs []string) []int + func (s *SampleSelector) DoUInt(vs []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 []float64) + func (a *SkewAgg) DoInt(vs []int64) + func (a *SkewAgg) DoUInt(vs []uint64) + 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) 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 []float64) + func (a *SpreadFloatAgg) Type() flux.ColType + func (a *SpreadFloatAgg) ValueFloat() float64 + type SpreadIntAgg struct + func (a *SpreadIntAgg) DoInt(vs []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 []uint64) + func (a *SpreadUIntAgg) Type() flux.ColType + func (a *SpreadUIntAgg) ValueUInt() uint64 + type StateTrackingOpSpec struct + CountLabel string + DurationLabel string + DurationUnit flux.Duration + Fn *semantic.FunctionExpression + TimeColumn string + func (s *StateTrackingOpSpec) Kind() flux.OperationKind + type StateTrackingProcedureSpec struct + CountLabel string + DurationLabel 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 []float64) + func (a *StddevAgg) DoInt(vs []int64) + func (a *StddevAgg) DoUInt(vs []uint64) + 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 []float64) + func (a *SumFloatAgg) Type() flux.ColType + func (a *SumFloatAgg) ValueFloat() float64 + type SumIntAgg struct + func (a *SumIntAgg) DoInt(vs []int64) + 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 []uint64) + 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 v0.7.0-rc3 Nov 5, 2018 v0.7.0-rc2 Nov 2, 2018 v0.7.0-rc1 Nov 1, 2018
Go to main page