experimental

package
v0.171.0 Latest Latest
Warning

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

 Go to latest Published: Jun 13, 2022 License: MIT Imports: 25 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"

Variables

View Source 
var FluxTestPackages = []*ast.Package{&ast.Package{
	BaseNode: ast.BaseNode{
		Comments: nil,
		Errors:   nil,
		Loc:      nil,
	},
	Files:   []*ast.File{},
	Package: "experimental_test",
	Path:    "experimental",
}}

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

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.

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.