aggregate

Documentation

Index

• Constants
• func NewTableTransformation(ctx context.Context, spec *TableProcedureSpec, id execute.DatasetID, ...) (execute.Transformation, execute.Dataset, error)
• type TableColumn
• type TableOpSpec
  • func (a *TableOpSpec) Kind() flux.OperationKind
• type TableProcedureSpec
  • func (s *TableProcedureSpec) Copy() plan.ProcedureSpec
  • func (s *TableProcedureSpec) Kind() plan.ProcedureKind

Constants

const TableKind = pkgpath + ".table"

Functions

func NewTableTransformation

func NewTableTransformation(ctx context.Context, spec *TableProcedureSpec, id execute.DatasetID, mem memory.Allocator) (execute.Transformation, execute.Dataset, error)

Types

type TableColumn

type TableColumn struct {
	Column  string
	Init    interpreter.ResolvedFunction
	Reduce  interpreter.ResolvedFunction
	Compute interpreter.ResolvedFunction
	As      string
	Fill    values.Value
}

type TableOpSpec

type TableOpSpec struct {
	Columns []TableColumn
}

func (*TableOpSpec) Kind

func (a *TableOpSpec) Kind() flux.OperationKind

type TableProcedureSpec

type TableProcedureSpec struct {
	plan.DefaultCost
	Columns []TableColumn
}

func (*TableProcedureSpec) Copy

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

func (*TableProcedureSpec) Kind

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