[
https://issues.apache.org/jira/browse/FLINK-37910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-37910:
------------------------------
Component/s: Table SQL / Planner
> Add StreamExecMultiJoin exec node
> ---------------------------------
>
> Key: FLINK-37910
> URL: https://issues.apache.org/jira/browse/FLINK-37910
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / Planner
> Reporter: Gustavo de Morais
> Assignee: Gustavo de Morais
> Priority: Major
> Fix For: 2.1.0
>
>
> 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)
