aggregate

Documentation

Index

• Constants
• Variables
• func NewTableTransformation(ctx context.Context, spec *TableProcedureSpec, id execute.DatasetID, ...) (execute.Transformation, execute.Dataset, error)
• func NewWindowTransformation(ctx context.Context, spec *WindowProcedureSpec, 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
• type WindowOpSpec
  • func (a *WindowOpSpec) Kind() flux.OperationKind
• type WindowProcedureSpec
  • func (s *WindowProcedureSpec) Copy() plan.ProcedureSpec
  • func (s *WindowProcedureSpec) Kind() plan.ProcedureKind

Constants

const TableKind = pkgpath + ".table"

const WindowKind = pkgpath + ".window"

Variables

var FluxTestPackages = []*ast.Package{&ast.Package{
	BaseNode: ast.BaseNode{
		Comments: nil,
		Errors:   nil,
		Loc:      nil,
	},
	Files:   []*ast.File{},
	Package: "aggregate_test",
	Path:    "contrib/jsternberg/aggregate",
}}

Functions

func NewTableTransformation

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

func NewWindowTransformation

func NewWindowTransformation(ctx context.Context, spec *WindowProcedureSpec, 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

type WindowOpSpec

type WindowOpSpec struct {
	TimeSrc string
	Window  execute.Window
	Columns []TableColumn
}

func (*WindowOpSpec) Kind

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

type WindowProcedureSpec

type WindowProcedureSpec struct {
	plan.DefaultCost
	*TableProcedureSpec
	TimeSrc string
	Window  execute.Window
}

func (*WindowProcedureSpec) Copy

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

func (*WindowProcedureSpec) Kind

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