Gustavo de Morais created FLINK-37890:
-----------------------------------------
Summary: FLIP-516: Extend FlinkLogicalMultiJoin to check for
common join key
Key: FLINK-37890
URL: https://issues.apache.org/jira/browse/FLINK-37890
Project: Flink
Issue Type: Sub-task
Reporter: Gustavo de Morais
We need to have the optimizer check if it's possible to use a
StreamingMultiJoinOperator according the [common key
restrictions|https://cwiki.apache.org/confluence/display/FLINK/FLIP-516%3A+Multi-Way+Join+Operator].
* Add Rule to check if the join chain respects the multi join common key
restrictions
** If not, create one multi join for each group of joins that respect. That
means 9 chained joins, 3 have one common key and 6 have another will generate
two chained multi joins.
** This could be addressed in the new FlinkLogicalMultiJoin produced by
FLINK-37889
Related:
* Add FlinkLogicalMultiJoin with all parameters we need +
FlinkJoinToFlinkMultiJoinRule to create it
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
