nodes

Documentation

Index

• type Aggregate
• type Distinct
  • func NewDistinct(source Node) *Distinct
  • func (o *Distinct) Run(execCtx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error
• type EventTimeBuffer
  • func NewEventTimeBuffer(source Node) *EventTimeBuffer
  • func (e *EventTimeBuffer) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error
• type Filter
  • func NewFilter(source Node, predicate Expression) *Filter
  • func (m *Filter) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error
• type GroupBy
  • func NewGroupBy(aggregatePrototypes []func() Aggregate, aggregateExprs []Expression, ...) *GroupBy
  • func (g *GroupBy) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error
• type LookupJoin
  • func NewLookupJoin(source, joined Node) *LookupJoin
  • func (s *LookupJoin) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error
• type Map
  • func NewMap(source Node, exprs []Expression) *Map
  • func (m *Map) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error
• type OrderBy
  • func NewBatchOrderBy(source Node, keyExprs []Expression, directionMultipliers []int) *OrderBy
  • func (o *OrderBy) Run(execCtx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error
• type StreamJoin
  • func NewStreamJoin(left, right Node, keyExprsLeft, keyExprsRight []Expression) *StreamJoin
  • func (s *StreamJoin) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error
• type Unnest
  • func NewUnnest(source Node, index int) *Unnest
  • func (u *Unnest) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error

Types

type Aggregate

type Aggregate interface {
	Add(retraction bool, value octosql.Value) bool
	Trigger() octosql.Value
}

type Distinct

type Distinct struct {
	// contains filtered or unexported fields
}

func NewDistinct

func NewDistinct(source Node) *Distinct

func (*Distinct) Run

func (o *Distinct) Run(execCtx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error

type EventTimeBuffer

type EventTimeBuffer struct {
	// contains filtered or unexported fields
}

func NewEventTimeBuffer

func NewEventTimeBuffer(source Node) *EventTimeBuffer

func (*EventTimeBuffer) Run

func (e *EventTimeBuffer) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error

type Filter

type Filter struct {
	// contains filtered or unexported fields
}

func NewFilter

func NewFilter(source Node, predicate Expression) *Filter

func (*Filter) Run

func (m *Filter) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error

type GroupBy

type GroupBy struct {
	// contains filtered or unexported fields
}

func NewGroupBy

func NewGroupBy(
	aggregatePrototypes []func() Aggregate,
	aggregateExprs []Expression,
	keyExprs []Expression,
	keyEventTimeIndex int,
	source Node,
	triggerPrototype func() Trigger,
) *GroupBy

func (*GroupBy) Run

func (g *GroupBy) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error

type LookupJoin

type LookupJoin struct {
	// contains filtered or unexported fields
}

func NewLookupJoin

func NewLookupJoin(source, joined Node) *LookupJoin

func (*LookupJoin) Run

func (s *LookupJoin) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error

type Map

type Map struct {
	// contains filtered or unexported fields
}

func NewMap

func NewMap(source Node, exprs []Expression) *Map

func (*Map) Run

func (m *Map) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error

type OrderBy

type OrderBy struct {
	// contains filtered or unexported fields
}

func NewBatchOrderBy

func NewBatchOrderBy(source Node, keyExprs []Expression, directionMultipliers []int) *OrderBy

func (*OrderBy) Run

func (o *OrderBy) Run(execCtx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error

type StreamJoin

type StreamJoin struct {
	// contains filtered or unexported fields
}

func NewStreamJoin

func NewStreamJoin(left, right Node, keyExprsLeft, keyExprsRight []Expression) *StreamJoin

func (*StreamJoin) Run

func (s *StreamJoin) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error

type Unnest

type Unnest struct {
	// contains filtered or unexported fields
}

func NewUnnest

func NewUnnest(source Node, index int) *Unnest

func (*Unnest) Run

func (u *Unnest) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error