Versions in this module Expand all Collapse all v1 v1.0.0 Mar 18, 2020 Changes in this version + type GlobalTableJoiner struct + Id int32 + KeyMapper KeyMapper + Registry store.Registry + Store string + Typ Type + ValueMapper ValueMapper + func (j *GlobalTableJoiner) AddChild(node topology.Node) + func (j *GlobalTableJoiner) AddChildBuilder(builder topology.NodeBuilder) + func (j *GlobalTableJoiner) Build() (topology.Node, error) + func (j *GlobalTableJoiner) ChildBuilders() []topology.NodeBuilder + func (j *GlobalTableJoiner) Childs() []topology.Node + func (j *GlobalTableJoiner) ID() int32 + func (j *GlobalTableJoiner) Join(ctx context.Context, key interface{}, leftVal interface{}) (joinedVal interface{}, err error) + func (j *GlobalTableJoiner) Name() string + func (j *GlobalTableJoiner) Next() bool + func (j *GlobalTableJoiner) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, next bool, err error) + func (j *GlobalTableJoiner) Type() topology.Type + type Joiner interface + Join func(ctx context.Context, key, val interface{}) (joinedVal interface{}, err error) + type KeyMapper func(key, value interface{}) (mappedKey interface{}, err error) + type SideJoiner struct + Id int32 + LeftWindow *Window + RightWindow *Window + Side string + ValueMapper ValueMapper + func (sj *SideJoiner) AddChild(node topology.Node) + func (sj *SideJoiner) AddChildBuilder(builder topology.NodeBuilder) + func (sj *SideJoiner) Build() (topology.Node, error) + func (sj *SideJoiner) ChildBuilders() []topology.NodeBuilder + func (sj *SideJoiner) Childs() []topology.Node + func (sj *SideJoiner) ID() int32 + func (sj *SideJoiner) Next() bool + func (sj *SideJoiner) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, cont bool, err error) + func (sj *SideJoiner) Type() topology.Type + type StreamJoiner struct + Id int32 + func (j *StreamJoiner) AddChild(node topology.Node) + func (j *StreamJoiner) AddChildBuilder(builder topology.NodeBuilder) + func (j *StreamJoiner) Build() (topology.Node, error) + func (j *StreamJoiner) ChildBuilders() []topology.NodeBuilder + func (j *StreamJoiner) Childs() []topology.Node + func (j *StreamJoiner) ID() int32 + func (j *StreamJoiner) Name() string + func (j *StreamJoiner) Next() bool + func (j *StreamJoiner) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, cont bool, err error) + func (j *StreamJoiner) Type() topology.Type + type Type int + const InnerJoin + const LeftJoin + type ValueMapper func(left, right interface{}) (joined interface{}, err error) + type Window struct + func NewWindow() *Window + func (w *Window) Read(key interface{}) (interface{}, bool) + func (w *Window) Write(key, value interface{})
Go to main page