aggregate

package
v0.184.2 Latest Latest
Warning

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

Go to latest
Published: Sep 26, 2022 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const TableKind = pkgpath + ".table"
View Source
const WindowKind = pkgpath + ".window"

Variables

This section is empty.

Functions

func NewWindowTransformation added in v0.85.0

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 (*TableProcedureSpec) Kind

type WindowOpSpec added in v0.85.0

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

func (*WindowOpSpec) Kind added in v0.85.0

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

type WindowProcedureSpec added in v0.85.0

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

func (*WindowProcedureSpec) Copy added in v0.85.0

func (*WindowProcedureSpec) Kind added in v0.85.0

Jump to

Keyboard shortcuts

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