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

experimental

package
v2.0.6 Latest Latest
Warning

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

Go to latest
Published: Apr 29, 2021 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source
const ExperimentalToKind = experimental.ExperimentalToKind

ToKind is the kind for the `to` flux function

Variables

This section is empty.

Functions

This section is empty.

Types

type LabelAndOffset

type LabelAndOffset struct {
	Label  string
	Offset int
}

type TablePointsMetadata

type TablePointsMetadata struct {
	MeasurementName string
	// The tags in the table (final element is left as nil, to be replaced by field name)
	Tags [][]byte
	// The offset in tags where to store the field name
	FieldKeyTagValueOffset int
	// The column offset in the input table where the _time column is stored
	TimestampOffset int
	// The labels and offsets of all the fields in the table
	Fields []LabelAndOffset
}

TablePointsMetadata stores state needed to write the points from one table.

func GetTablePointsMetadata

func GetTablePointsMetadata(tbl flux.Table) (*TablePointsMetadata, error)

type ToOpSpec

type ToOpSpec struct {
	Bucket   string `json:"bucket"`
	BucketID string `json:"bucketID"`
	Org      string `json:"org"`
	OrgID    string `json:"orgID"`
	Host     string `json:"host"`
	Token    string `json:"token"`
}

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

func (*ToOpSpec) BucketsAccessed

func (o *ToOpSpec) BucketsAccessed(orgID *platform.ID) (readBuckets, writeBuckets []platform.BucketFilter)

BucketsAccessed returns the buckets accessed by the spec.

func (ToOpSpec) Kind

func (ToOpSpec) Kind() flux.OperationKind

Kind returns the kind for the ToOpSpec function.

func (*ToOpSpec) ReadArgs

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

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

type ToProcedureSpec

type ToProcedureSpec struct {
	plan.DefaultCost
	Spec *ToOpSpec
}

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

func (*ToProcedureSpec) Copy

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

func (*ToProcedureSpec) Kind

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

type ToTransformation

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

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

func NewToTransformation

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

func (*ToTransformation) Finish

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

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

Process does the actual work for the ToTransformation.

func (*ToTransformation) RetractTable

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

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

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

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

Jump to

Keyboard shortcuts

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