You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by go...@apache.org on 2021/01/18 12:37:31 UTC
[flink] branch master updated (5395c5f -> 5c6e261)

This is an automated email from the ASF dual-hosted git repository.

godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 5395c5f  [FLINK-20997][tests] Generate yarn classpath before test phase
     add 5c6e261  [FLINK-20925][table-planner-blink] Introduce StreamPhysicalLookupJoin and BatchPhysicalLookupJoin, and make related Stream/Batch ExecLookupJoin only extends from ExecNode

No new revisions were added by this update.

Summary of changes:
 ...ExecCorrelate.java => BatchExecLookupJoin.java} |  28 +-
 .../nodes/exec/common/CommonExecLookupJoin.java    | 496 +++++++++++++++
 ...xecCorrelate.java => StreamExecLookupJoin.java} |  31 +-
 .../table/planner/plan/utils/LookupJoinUtil.java   |  68 ++
 .../planner/codegen/LookupJoinCodeGenerator.scala  |  34 +-
 .../plan/metadata/FlinkRelMdColumnUniqueness.scala |   4 +-
 .../plan/metadata/FlinkRelMdUniqueKeys.scala       |   4 +-
 .../plan/nodes/common/CommonLookupJoin.scala       | 687 ---------------------
 .../nodes/common/CommonPhysicalLookupJoin.scala    | 352 +++++++++++
 ...kupJoin.scala => BatchPhysicalLookupJoin.scala} |  44 +-
 ...upJoin.scala => StreamPhysicalLookupJoin.scala} |  48 +-
 .../FlinkChangelogModeInferenceProgram.scala       |   4 +-
 .../planner/plan/rules/FlinkBatchRuleSets.scala    |   4 +-
 .../planner/plan/rules/FlinkStreamRuleSets.scala   |   4 +-
 .../rules/common/CommonTemporalTableJoinRule.scala |   4 +-
 ...gicalCorrelateToJoinFromTemporalTableRule.scala |   4 +-
 ...ule.scala => BatchPhysicalLookupJoinRule.scala} |  20 +-
 .../physical/common/CommonLookupJoinRule.scala     |   8 +-
 ...le.scala => StreamPhysicalLookupJoinRule.scala} |  20 +-
 .../plan/batch/sql/join/LookupJoinTest.scala       |   3 +
 .../plan/metadata/FlinkRelMdHandlerTestBase.scala  |   4 +-
 .../plan/stream/sql/join/LookupJoinTest.scala      |   3 +
 22 files changed, 1052 insertions(+), 822 deletions(-)
 copy flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/{BatchExecCorrelate.java => BatchExecLookupJoin.java} (67%)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecLookupJoin.java
 copy flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{StreamExecCorrelate.java => StreamExecLookupJoin.java} (67%)
 delete mode 100644 flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonLookupJoin.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalLookupJoin.scala
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecLookupJoin.scala => BatchPhysicalLookupJoin.scala} (63%)
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecLookupJoin.scala => StreamPhysicalLookupJoin.scala} (63%)
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/{BatchExecLookupJoinRule.scala => BatchPhysicalLookupJoinRule.scala} (82%)
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecLookupJoinRule.scala => StreamPhysicalLookupJoinRule.scala} (82%)