experimental

package
v0.175.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 19, 2022 License: MIT Imports: 25 Imported by: 1

Documentation

Index

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 Catch added in v0.174.0

func Catch() values.Function

func MakeChainFunction added in v0.68.0

func MakeChainFunction() values.Function

func NewDiffTransformation added in v0.175.0

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 added in v0.65.0

func NewMergeJoinCache(ctx context.Context, alloc memory.Allocator, fn interpreter.ResolvedFunction, left, right execute.DatasetID) *mergeJoinCache

func NewMergeJoinTransformation added in v0.65.0

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

func NewPreviewTransformation added in v0.167.0

func NewPreviewTransformation(id execute.DatasetID, spec *PreviewProcedureSpec, mem memory.Allocator) (execute.Transformation, execute.Dataset, error)

func NewSetTransformation added in v0.40.0

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

func NewUnpivotTransformation added in v0.172.0

func NewUnpivotTransformation(spec *UnpivotProcedureSpec, id execute.DatasetID, alloc memory.Allocator) (execute.Transformation, execute.Dataset, error)

Types

type DiffOpSpec added in v0.175.0

type DiffOpSpec struct{}

func (*DiffOpSpec) Kind added in v0.175.0

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

type DiffProcedureSpec added in v0.175.0

type DiffProcedureSpec struct {
	plan.DefaultCost
}

func (*DiffProcedureSpec) Copy added in v0.175.0

func (*DiffProcedureSpec) Kind added in v0.175.0

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 (*GroupProcedureSpec) Kind

type JoinOpSpec added in v0.65.0

type JoinOpSpec struct {
	Left  flux.OperationID             `json:"left"`
	Right flux.OperationID             `json:"right"`
	Fn    interpreter.ResolvedFunction `json:"fn"`
	// contains filtered or unexported fields
}

func (*JoinOpSpec) IDer added in v0.65.0

func (s *JoinOpSpec) IDer(ider flux.IDer)

func (*JoinOpSpec) Kind added in v0.65.0

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

type MergeJoinProcedureSpec added in v0.65.0

type MergeJoinProcedureSpec struct {
	plan.DefaultCost

	Fn interpreter.ResolvedFunction `json:"fn"`
}

func (*MergeJoinProcedureSpec) Copy added in v0.65.0

func (*MergeJoinProcedureSpec) Kind added in v0.65.0

type PreviewOpSpec added in v0.167.0

type PreviewOpSpec struct {
	NRows   int64
	NTables int64
}

func (*PreviewOpSpec) Kind added in v0.167.0

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

type PreviewProcedureSpec added in v0.167.0

type PreviewProcedureSpec struct {
	plan.DefaultCost
	NRows   int64
	NTables int64
}

func (*PreviewProcedureSpec) Copy added in v0.167.0

func (*PreviewProcedureSpec) Kind added in v0.167.0

type RowIterator added in v0.65.0

type RowIterator struct {
	// contains filtered or unexported fields
}

RowIterator iterates over the rows of several column readers

func NewRowIterator added in v0.65.0

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

type SetOpSpec added in v0.40.0

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

func (*SetOpSpec) Kind added in v0.40.0

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

type SetProcedureSpec added in v0.40.0

type SetProcedureSpec struct {
	plan.DefaultCost
	Object values.Object
}

func (*SetProcedureSpec) Copy added in v0.40.0

func (*SetProcedureSpec) Kind added in v0.40.0

type UnpivotOpSpec added in v0.172.0

type UnpivotOpSpec struct{}

func (*UnpivotOpSpec) Kind added in v0.172.0

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

type UnpivotProcedureSpec added in v0.172.0

type UnpivotProcedureSpec struct {
	plan.DefaultCost
}

func (*UnpivotProcedureSpec) Copy added in v0.172.0

func (*UnpivotProcedureSpec) Kind added in v0.172.0

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL