experimental

package
v0.194.5 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2023 License: MIT Imports: 26 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 (s *DiffProcedureSpec) Copy() plan.ProcedureSpec

func (*DiffProcedureSpec) Kind added in v0.175.0 

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

type JoinOpSpec struct {
	Fn interpreter.ResolvedFunction
	// contains filtered or unexported fields
}

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 (s *MergeJoinProcedureSpec) Copy() plan.ProcedureSpec

func (*MergeJoinProcedureSpec) Kind added in v0.65.0 

func (s *MergeJoinProcedureSpec) Kind() plan.ProcedureKind

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 (s *PreviewProcedureSpec) Copy() plan.ProcedureSpec

func (*PreviewProcedureSpec) Kind added in v0.167.0 

func (s *PreviewProcedureSpec) Kind() plan.ProcedureKind

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 (s *SetProcedureSpec) Copy() plan.ProcedureSpec

func (*SetProcedureSpec) Kind added in v0.40.0 

func (s *SetProcedureSpec) Kind() plan.ProcedureKind

type UnpivotOpSpec added in v0.172.0 

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

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
	OtherColumns []string
}

func (*UnpivotProcedureSpec) Copy added in v0.172.0 

func (s *UnpivotProcedureSpec) Copy() plan.ProcedureSpec

func (*UnpivotProcedureSpec) Kind added in v0.172.0 

func (s *UnpivotProcedureSpec) Kind() plan.ProcedureKind

Source Files

View all Source files

Directories

Path Synopsis
date
boundaries
requests
rdp

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.