experimental

Documentation

Index

• Constants
• func NewGroupTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *GroupProcedureSpec) *groupTransformation
• type GroupOpSpec
  • func (s *GroupOpSpec) Kind() flux.OperationKind
• type GroupProcedureSpec
  • func (s *GroupProcedureSpec) Copy() plan.ProcedureSpec
  • func (s *GroupProcedureSpec) Kind() plan.ProcedureKind

Constants

const ExperimentalGroupKind = "experimental-group"

Functions

func NewGroupTransformation

func NewGroupTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *GroupProcedureSpec) *groupTransformation

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