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)
- nextProcessor
function(StreamEvent[]) returns (())
- joinType JoinType
- tableQuery
function(StreamEvent) returns (map)
Methods
Joins the incoming events to the stream with the given table.
Set the properties required for joining.
Fields
Joins the incoming events to the stream with the given table.
Parameters
- streamEvents StreamEvent[]
-
The stream events being joined with the table.
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.