experimental

package
v0.195.1 Latest Latest
Warning

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

Go to latest
Published: Sep 17, 2023 License: MIT Imports: 26 Imported by: 0

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

func Catch() values.Function

func MakeChainFunction

func MakeChainFunction() values.Function

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

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

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

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

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

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

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

Jump to

Keyboard shortcuts

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