package experimental

import "github.com/influxdata/flux/stdlib/experimental"

Index ¶

• Constants
• func Catch() values.Function
• func MakeChainFunction() values.Function
• func NewDiffTransformation(id execute.DatasetID, spec *DiffProcedureSpec, wantID, gotID execute.DatasetID, mem memory.Allocator) (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, left, right execute.DatasetID) *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
• func (s *DiffOpSpec) Kind() flux.OperationKind
• type DiffProcedureSpec
• func (s *DiffProcedureSpec) Copy() plan.ProcedureSpec
• func (s *DiffProcedureSpec) Kind() plan.ProcedureKind
• type GroupOpSpec
• func (s *GroupOpSpec) Kind() flux.OperationKind
• type GroupProcedureSpec
• func (s *GroupProcedureSpec) Copy() plan.ProcedureSpec
• func (s *GroupProcedureSpec) Kind() plan.ProcedureKind
• type JoinOpSpec
• func (s *JoinOpSpec) Kind() flux.OperationKind
• type MergeJoinProcedureSpec
• func (s *MergeJoinProcedureSpec) Copy() plan.ProcedureSpec
• func (s *MergeJoinProcedureSpec) Kind() plan.ProcedureKind
• type PreviewOpSpec
• func (s *PreviewOpSpec) Kind() flux.OperationKind
• type PreviewProcedureSpec
• func (s *PreviewProcedureSpec) Copy() plan.ProcedureSpec
• func (s *PreviewProcedureSpec) Kind() plan.ProcedureKind
• type RowIterator
• func NewRowIterator(columns []flux.ColMeta, readers []flux.ColReader, timeCol int) *RowIterator
• type SetOpSpec
• func (s *SetOpSpec) Kind() flux.OperationKind
• type SetProcedureSpec
• func (s *SetProcedureSpec) Copy() plan.ProcedureSpec
• func (s *SetProcedureSpec) Kind() plan.ProcedureKind
• type UnpivotOpSpec
• func (s *UnpivotOpSpec) Kind() flux.OperationKind
• type UnpivotProcedureSpec
• func (s *UnpivotProcedureSpec) Copy() plan.ProcedureSpec
• func (s *UnpivotProcedureSpec) Kind() plan.ProcedureKind

Constants ¶

const (
	DiffKind       = "experimental.diff"
	DefaultEpsilon = 1e-6
	DiffColumn     = "_diff"
)

const CatchKind = "catch"

const ExperimentalGroupKind = "experimental-group"

const PreviewKind = "experimental.preview"

const SetKind = "setExperimental"

const UnpivotKind = "experimental.unpivot"

Functions ¶

func Catch ¶

func Catch() values.Function

func MakeChainFunction ¶

func MakeChainFunction() values.Function

func NewDiffTransformation ¶

func NewDiffTransformation(id execute.DatasetID, spec *DiffProcedureSpec, wantID, gotID execute.DatasetID, mem memory.Allocator) (execute.Transformation, execute.Dataset, error)

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 NewMergeJoinTransformation ¶

func NewMergeJoinTransformation(d execute.Dataset, cache *mergeJoinCache) *mergeJoinTransformation

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 ¶

type GroupOpSpec struct {
	Mode    string   `json:"mode"`
	Columns []string `json:"columns"`
}

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/influxdata/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 ¶

type PreviewOpSpec struct {
	NRows   int64
	NTables int64
}

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 ¶

func NewRowIterator(columns []flux.ColMeta, readers []flux.ColReader, timeCol int) *RowIterator

type SetOpSpec ¶

type SetOpSpec struct {
	Object values.Object `json:"object"`
}

func (*SetOpSpec) Kind ¶

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

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 ¶

catch.go chain.go count.go diff.go distinct.go fill.go first.go group.go histogram.go histogram_quantile.go integral.go join.go kaufmansAMA.go last.go max.go mean.go min.go mode.go object_keys.go preview.go quantile.go set.go skew.go spread.go stddev.go sum.go unique.go unpivot.go window.go

Directories ¶