Gustavo de Morais created FLINK-37910:
-----------------------------------------
Summary: FLIP-516: Add StreamExecMultiJoin exec node
Key: FLINK-37910
URL: https://issues.apache.org/jira/browse/FLINK-37910
Project: Flink
Issue Type: Sub-task
Reporter: Gustavo de Morais
We need to add a new StreamExecMultiJoin to instantiate the
StreamingMultiJoinOperator. It needs to pass down the parameters in the
expected format from the operator.
Specially, it has to convert the RexNodes for the join conditions into
GeneratedJoinConditions that respect the relative index of each input.
We need to update the operator to use a JoinedRowData so we can use
GeneratedJoinConditions with the left side being all inputs to the left from
inputId and the right side being the current record for inputId we're iterating.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
