operator

Documentation

Index

• func Init()
• func InvokeWithParameters(any any, methodName string, args ...any) []reflect.Value
• func InvokeWithoutParameters(any any, methodName string) []reflect.Value
• func Rowstamp(ingressRow *data.IngressRow, rowFieldName string) (rowstamp int)
• func Timestamp(ingressRow *data.IngressRow, timeFieldName string) (timestamp time.Time)
• type Aggregate
  • func (o *Aggregate) Init(node *fluid.Node)
  • func (o *Aggregate) Reset()
  • func (o *Aggregate) Update(inRow data.IngressRow)
  • func (o *Aggregate) Value(outRow *data.AggregateRow)
• type Condition
• type Egress
  • func (o *Egress) Init(node *fluid.Node)
• type Filter
  • func (o *Filter) Init(node *fluid.Node)
• type Ingress
  • func (o *Ingress) Ingress(record []string, row *data.IngressRow)
  • func (o *Ingress) Init(node *fluid.Node)
• type Operator
  • func (s *Operator) Init(node *fluid.Node)
• type Project
  • func (o *Project) Init(node *fluid.Node)
  • func (o *Project) Project(inRow *data.AggregateRow, outRow *data.EgressRow)
• type Window
  • func (op *Window) Init(node *fluid.Node)

Functions

func Init

func Init()

func InvokeWithParameters

func InvokeWithParameters(any any, methodName string, args ...any) []reflect.Value

func InvokeWithoutParameters

func InvokeWithoutParameters(any any, methodName string) []reflect.Value

func Rowstamp

func Rowstamp(ingressRow *data.IngressRow, rowFieldName string) (rowstamp int)

func Timestamp

func Timestamp(ingressRow *data.IngressRow, timeFieldName string) (timestamp time.Time)

Types

type Aggregate

type Aggregate struct {
	Operator
	// contains filtered or unexported fields
}

func (*Aggregate) Init

func (o *Aggregate) Init(node *fluid.Node)

func (*Aggregate) Reset

func (o *Aggregate) Reset()

func (*Aggregate) Update

func (o *Aggregate) Update(inRow data.IngressRow)

func (*Aggregate) Value

func (o *Aggregate) Value(outRow *data.AggregateRow)

type Condition

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

type Egress

type Egress struct {
	Operator
}

func (*Egress) Init

func (o *Egress) Init(node *fluid.Node)

type Filter

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

func (*Filter) Init

func (o *Filter) Init(node *fluid.Node)

type Ingress

type Ingress struct {
	Operator
}

func (*Ingress) Ingress

func (o *Ingress) Ingress(record []string, row *data.IngressRow)

func (*Ingress) Init

func (o *Ingress) Init(node *fluid.Node)

type Operator

type Operator struct {
	OutputFieldNames        []string
	OutputFieldTypes        []fluid.FieldType
	OutputFieldNamesToTypes map[string]fluid.FieldType
	GroupFieldNames         []string
	GroupFieldTypes         []fluid.FieldType
	GroupFieldNamesToTypes  map[string]fluid.FieldType
}

func (*Operator) Init

func (s *Operator) Init(node *fluid.Node)

type Project

type Project struct {
	Operator
}

func (*Project) Init

func (o *Project) Init(node *fluid.Node)

func (*Project) Project

func (o *Project) Project(inRow *data.AggregateRow, outRow *data.EgressRow)

type Window

type Window struct {
	Operator

	WindowType               string
	IntervalField            string
	IntervalType             string
	IntervalUnit             string
	IntervalAmount           string
	SequenceField            string
	IntervalRows             int64
	TickerSeconds            float64
	SessionIncludeClosingRow bool
}

func (*Window) Init

func (op *Window) Init(node *fluid.Node)