Versions in this module Expand all Collapse all v1 v1.3.3 May 25, 2022 v1.3.2 Aug 16, 2021 v1.3.1 Aug 11, 2021 v1.3.0 Oct 15, 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 Repartition struct + Enable bool + KeyEncoder encoding.Builder + StreamSide Side + Topic RepartitionTopic + ValueEncoder encoding.Builder + func (r Repartition) Validate(s Side) error + type RepartitionOption func(sink *RepartitionOptions) + func RepartitionLeftStream(keyEncodingBuilder, valueEncodingBuilder encoding.Builder) RepartitionOption + func RepartitionRightStream(keyEncodingBuilder, valueEncodingBuilder encoding.Builder) RepartitionOption + type RepartitionOptions struct + LeftRepartition Repartition + LeftTopic func(string) string + RightRepartition Repartition + RightTopic func(string) string + func (iOpts *RepartitionOptions) Apply(options ...RepartitionOption) + type RepartitionTopic struct + MinInSycReplicas int + Name string + NumOfPartitions int + ReplicationFactor int + Suffix string + type Side int + const LeftSide + const RightSide + 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