Joins tuple from two input streams iff their timestamps are overlapping and if the optional predicate validates to true.

Parameters

• predicate: The predicate to evaluate over each incoming tuple from left and right
• card: ONE_ONE, ONE_MANY, MANY_ONE, MANY_MANY (same as empty, see below)

• SweepAreaName: Overwrite the default rule for using sweepAreas (e.g. TIJoinSA is used if the predicate contains other operations than "==", HashJoinSA is used if the predicate only contains "==")

• elementsizeport0, elementsizeport0 (see below)
• group_by_port_0, group_by_port_1 (see below)

The card parameter describes how input elements can be joined. This optional information can be used to optimize processing (i.e. using less memory, because elements can earlier be discarded).

• • ONE_ONE: In each input stream there is exactly one corresponding object. With this setting, windows can potentially be avoided.
  • ONE_MANY: Each element in the right input stream has exactly one corresponding element in the left input stream
  • MANY_ONE: Each element in the left input stream has exactly one corresponding element in the right input stream
  • MANY_MANY: For each element in both input streams there may be multiple corresponding elements.

Example

PQL

output = join({predicate = 'auction_id = auction'}, left, right)

CQL

SELECT * FROM left, right WHERE auction_id = auction

Element Join

JOIN({
    elementsizeport1 = 1,
    elementsizeport0 = 1,
    group_by_port_1 = ['id'],
    group_by_port_0 = ['id_center']              
}, left, right)