Documentation ¶
Index ¶
- Constants
- func Catch() values.Function
- func MakeChainFunction() values.Function
- func NewDiffTransformation(id execute.DatasetID, spec *DiffProcedureSpec, wantID, gotID execute.DatasetID, ...) (execute.Transformation, execute.Dataset, error)
- func NewGroupTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *GroupProcedureSpec) *groupTransformation
- func NewMergeJoinCache(ctx context.Context, alloc memory.Allocator, fn interpreter.ResolvedFunction, ...) *mergeJoinCache
- func NewMergeJoinTransformation(d execute.Dataset, cache *mergeJoinCache) *mergeJoinTransformation
- func NewPreviewTransformation(id execute.DatasetID, spec *PreviewProcedureSpec, mem memory.Allocator) (execute.Transformation, execute.Dataset, error)
- func NewSetTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *SetProcedureSpec) execute.Transformation
- func NewUnpivotTransformation(spec *UnpivotProcedureSpec, id execute.DatasetID, alloc memory.Allocator) (execute.Transformation, execute.Dataset, error)
- type DiffOpSpec
- type DiffProcedureSpec
- type GroupOpSpec
- type GroupProcedureSpec
- type JoinOpSpec
- type MergeJoinProcedureSpec
- type PreviewOpSpec
- type PreviewProcedureSpec
- type RowIterator
- type SetOpSpec
- type SetProcedureSpec
- type UnpivotOpSpec
- type UnpivotProcedureSpec
Constants ¶
View Source
const ( DiffKind = "experimental.diff" DefaultEpsilon = 1e-6 DiffColumn = "_diff" )
View Source
const CatchKind = "catch"
View Source
const ExperimentalGroupKind = "experimental-group"
View Source
const PreviewKind = "experimental.preview"
View Source
const SetKind = "setExperimental"
View Source
const UnpivotKind = "experimental.unpivot"
Variables ¶
This section is empty.
Functions ¶
func MakeChainFunction ¶
func NewDiffTransformation ¶
func NewGroupTransformation ¶
func NewGroupTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *GroupProcedureSpec) *groupTransformation
func NewMergeJoinCache ¶
func NewMergeJoinCache(ctx context.Context, alloc memory.Allocator, fn interpreter.ResolvedFunction, left, right execute.DatasetID) *mergeJoinCache
func NewPreviewTransformation ¶
func NewPreviewTransformation(id execute.DatasetID, spec *PreviewProcedureSpec, mem memory.Allocator) (execute.Transformation, execute.Dataset, error)
func NewSetTransformation ¶
func NewSetTransformation( d execute.Dataset, cache execute.TableBuilderCache, spec *SetProcedureSpec, ) execute.Transformation
func NewUnpivotTransformation ¶
func NewUnpivotTransformation(spec *UnpivotProcedureSpec, id execute.DatasetID, alloc memory.Allocator) (execute.Transformation, execute.Dataset, error)
Types ¶
type DiffOpSpec ¶
type DiffOpSpec struct{}
func (*DiffOpSpec) Kind ¶
func (s *DiffOpSpec) Kind() flux.OperationKind
type DiffProcedureSpec ¶
type DiffProcedureSpec struct {
plan.DefaultCost
}
func (*DiffProcedureSpec) Copy ¶
func (s *DiffProcedureSpec) Copy() plan.ProcedureSpec
func (*DiffProcedureSpec) Kind ¶
func (s *DiffProcedureSpec) Kind() plan.ProcedureKind
type GroupOpSpec ¶
GroupOpSpec in package experimental defines a special group() function that has just one mode called "extend", which adds additional columns to the group key. This is a workaround until schema introspection is implemented:
https://github.com/InfluxCommunity/flux/issues/27
Most of this code has simply been copied from stdlib/universe/group.go
func (*GroupOpSpec) Kind ¶
func (s *GroupOpSpec) Kind() flux.OperationKind
type GroupProcedureSpec ¶
type GroupProcedureSpec struct { plan.DefaultCost GroupKeys []string }
func (*GroupProcedureSpec) Copy ¶
func (s *GroupProcedureSpec) Copy() plan.ProcedureSpec
func (*GroupProcedureSpec) Kind ¶
func (s *GroupProcedureSpec) Kind() plan.ProcedureKind
type JoinOpSpec ¶
type JoinOpSpec struct { Fn interpreter.ResolvedFunction // contains filtered or unexported fields }
func (*JoinOpSpec) Kind ¶
func (s *JoinOpSpec) Kind() flux.OperationKind
type MergeJoinProcedureSpec ¶
type MergeJoinProcedureSpec struct { plan.DefaultCost Fn interpreter.ResolvedFunction `json:"fn"` }
func (*MergeJoinProcedureSpec) Copy ¶
func (s *MergeJoinProcedureSpec) Copy() plan.ProcedureSpec
func (*MergeJoinProcedureSpec) Kind ¶
func (s *MergeJoinProcedureSpec) Kind() plan.ProcedureKind
type PreviewOpSpec ¶
func (*PreviewOpSpec) Kind ¶
func (s *PreviewOpSpec) Kind() flux.OperationKind
type PreviewProcedureSpec ¶
type PreviewProcedureSpec struct { plan.DefaultCost NRows int64 NTables int64 }
func (*PreviewProcedureSpec) Copy ¶
func (s *PreviewProcedureSpec) Copy() plan.ProcedureSpec
func (*PreviewProcedureSpec) Kind ¶
func (s *PreviewProcedureSpec) Kind() plan.ProcedureKind
type RowIterator ¶
type RowIterator struct {
// contains filtered or unexported fields
}
RowIterator iterates over the rows of several column readers
func NewRowIterator ¶
type SetProcedureSpec ¶
type SetProcedureSpec struct { plan.DefaultCost Object values.Object }
func (*SetProcedureSpec) Copy ¶
func (s *SetProcedureSpec) Copy() plan.ProcedureSpec
func (*SetProcedureSpec) Kind ¶
func (s *SetProcedureSpec) Kind() plan.ProcedureKind
type UnpivotOpSpec ¶
type UnpivotOpSpec struct {
// contains filtered or unexported fields
}
func (*UnpivotOpSpec) Kind ¶
func (s *UnpivotOpSpec) Kind() flux.OperationKind
type UnpivotProcedureSpec ¶
type UnpivotProcedureSpec struct { plan.DefaultCost OtherColumns []string }
func (*UnpivotProcedureSpec) Copy ¶
func (s *UnpivotProcedureSpec) Copy() plan.ProcedureSpec
func (*UnpivotProcedureSpec) Kind ¶
func (s *UnpivotProcedureSpec) Kind() plan.ProcedureKind
Source Files ¶
Click to show internal directories.
Click to hide internal directories.