[
https://issues.apache.org/jira/browse/FLINK-37910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-37910.
--------------------------------
Fix Version/s: 2.1.0
Assignee: Gustavo de Morais
Resolution: Fixed
Fixed in master: ed9aebe1680be720e23d6321623253f66b2032d4
> 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
> 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)
