Object - streams : TableJoinProcessor

The TableJoinProcessor object handles joining streams with in-memory tables in ballerina. nextProcessor is the process function of the next processor, which can be a Select processor, Aggregator processor, Having processor.. etc. The streamName is the stream of the join and its attached window is 'windowInstance. The tableName is the name of the table with which the stream is joined. The joinType is the type of the join and it can be any value defined by streams:JoinType.

Constructor

__init

( function(StreamEvent[]) returns (()) nextProcessor, JoinType joinType, function(StreamEvent) returns (map) tableQuery)

Methods

Fields

  • windowInstance Window?
  • description

  • streamName string
  • description

  • tableName string
  • description

  • lockField int 0
  • description

process

Joins the incoming events to the stream with the given table.

Parameters

  • streamEvents StreamEvent[]
  • The stream events being joined with the table.

setJoinProperties

Set the properties required for joining.

Parameters

  • tn string
  • The name of the table being joined with the stream.

  • sn string
  • The name of the stream being joined with the table.

  • wi Window
  • The window instance which is attached to the stream.