nodes

Documentation

Index

• type Aggregate
• type CustomTriggerGroupBy
  • func NewCustomTriggerGroupBy(aggregatePrototypes []func() Aggregate, aggregateExprs []Expression, ...) *CustomTriggerGroupBy
  • func (g *CustomTriggerGroupBy) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error
• 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 InMemoryRecords
  • func NewInMemoryRecords(records []execution.Record) *InMemoryRecords
  • func (r *InMemoryRecords) Run(ctx execution.ExecutionContext, produce execution.ProduceFn, ...) error
• type Limit
  • func NewLimit(source Node, limit Expression) *Limit
  • func (m *Limit) 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 OrderSensitiveTransform
  • func NewOrderSensitiveTransform(source Node, orderByKeyExprs []Expression, orderByDirectionMultipliers []int, ...) *OrderSensitiveTransform
  • func (o *OrderSensitiveTransform) Run(execCtx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error
• type OuterJoin
  • func NewOuterJoin(left, right Node, leftFieldCount, rightFieldCount int, ...) *OuterJoin
  • func (s *OuterJoin) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error
• type SimpleGroupBy
  • func NewSimpleGroupBy(aggregatePrototypes []func() Aggregate, aggregateExprs []Expression, ...) *SimpleGroupBy
  • func (g *SimpleGroupBy) Run(ctx 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 CustomTriggerGroupBy

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

func NewCustomTriggerGroupBy

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

func (*CustomTriggerGroupBy) Run

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

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 InMemoryRecords

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

func NewInMemoryRecords

func NewInMemoryRecords(records []execution.Record) *InMemoryRecords

func (*InMemoryRecords) Run

func (r *InMemoryRecords) Run(ctx execution.ExecutionContext, produce execution.ProduceFn, metaSend execution.MetaSendFn) error

type Limit

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

func NewLimit

func NewLimit(source Node, limit Expression) *Limit

func (*Limit) Run

func (m *Limit) 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 OrderSensitiveTransform

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

func NewOrderSensitiveTransform

func NewOrderSensitiveTransform(source Node, orderByKeyExprs []Expression, orderByDirectionMultipliers []int, limit *Expression, noRetractionsPossible bool) *OrderSensitiveTransform

func (*OrderSensitiveTransform) Run

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

type OuterJoin

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

func NewOuterJoin

func NewOuterJoin(left, right Node, leftFieldCount, rightFieldCount int, keyExprsLeft, keyExprsRight []Expression, isOuterLeft, isOuterRight bool) *OuterJoin

func (*OuterJoin) Run

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

type SimpleGroupBy

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

SimpleGroupBy is a special group by that's much faster than the CustomTriggerGroupBy but only works with no custom triggers.

func NewSimpleGroupBy

func NewSimpleGroupBy(
	aggregatePrototypes []func() Aggregate,
	aggregateExprs []Expression,
	keyExprs []Expression,
	source Node,
) *SimpleGroupBy

func (*SimpleGroupBy) Run

func (g *SimpleGroupBy) Run(ctx 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