Help us shape the future of Go! Take the 2026 Go Developer Survey

experimental

package
v0.172.0 Latest Latest
Warning

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

 Go to latest Published: Jun 24, 2022 License: MIT Imports: 26 Imported by: 1

Documentation

Index

Constants

View Source 
const ExperimentalGroupKind = "experimental-group"
View Source 
const PreviewKind = "experimental.preview"
View Source 
const SetKind = "setExperimental"
View Source 
const ToKind = "experimental-to"
View Source 
const UnpivotKind = "experimental.unpivot"

Variables

This section is empty.

Functions

func MakeChainFunction added in v0.68.0 

func MakeChainFunction() values.Function

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 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 {
	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 LabelAndOffset added in v0.121.0 

type LabelAndOffset struct {
	Label  string
	Offset int
}

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

type ToOpSpec struct {
	Org    influxdb.NameOrID
	Bucket influxdb.NameOrID
	Host   string
	Token  string
}

ToOpSpec is the flux.OperationSpec for the `to` flux function.

func (ToOpSpec) Kind added in v0.121.0 

func (ToOpSpec) Kind() flux.OperationKind

Kind returns the kind for the ToOpSpec function.

func (*ToOpSpec) ReadArgs added in v0.121.0 

func (s *ToOpSpec) ReadArgs(args flux.Arguments) error

ReadArgs reads the args from flux.Arguments into the op spec

type ToProcedureSpec added in v0.121.0 

type ToProcedureSpec struct {
	plan.DefaultCost
	Config influxdb.Config
}

ToProcedureSpec is the procedure spec for the `to` flux function.

func (*ToProcedureSpec) Copy added in v0.121.0 

func (o *ToProcedureSpec) Copy() plan.ProcedureSpec

Copy clones the procedure spec for `to` flux function.

func (*ToProcedureSpec) Kind added in v0.121.0 

func (o *ToProcedureSpec) Kind() plan.ProcedureKind

Kind returns the kind for the procedure spec for the `to` flux function.

type ToTransformation added in v0.121.0 

type ToTransformation struct {
	execute.ExecutionNode
	// contains filtered or unexported fields
}

ToTransformation is the transformation for the `to` flux function.

func NewToTransformation added in v0.121.0 

func NewToTransformation(ctx context.Context, d execute.Dataset, cache execute.TableBuilderCache, s *ToProcedureSpec) (*ToTransformation, error)

NewToTransformation returns a new *ToTransformation with the appropriate fields set.

func (*ToTransformation) Finish added in v0.121.0 

func (t *ToTransformation) Finish(id execute.DatasetID, err error)

Finish is called after the `to` flux function's transformation is done processing.

func (*ToTransformation) Process added in v0.121.0 

func (t *ToTransformation) Process(id execute.DatasetID, tbl flux.Table) error

Process does the actual work for the ToTransformation.

func (*ToTransformation) RetractTable added in v0.121.0 

func (t *ToTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error

RetractTable retracts the table for the transformation for the `to` flux function.

func (*ToTransformation) UpdateProcessingTime added in v0.121.0 

func (t *ToTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error

UpdateProcessingTime updates the processing time for the transformation for the `to` flux function.

func (*ToTransformation) UpdateWatermark added in v0.121.0 

func (t *ToTransformation) UpdateWatermark(id execute.DatasetID, pt execute.Time) error

UpdateWatermark updates the watermark for the transformation for the `to` flux function.

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 (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
requests

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.