[flink] branch master updated (92b2196 -> a34552e)

[go...@apache.org]

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 92b2196  [FLINK-20453][runtime][checkpoint] Move checkpointing classes to an appropriate package
     add 7d55eb3  [FLINK-20783][table-planner-blink] Introduce BatchPhysicalHashJoin, and make BatchExecHashJoin only extended from ExecNode
     add 40c65d4  [FLINK-20783][table-planner-blink] Introduce BatchPhysicalNestedLoopJoin, and make BatchExecNestedLoopJoin only extended from ExecNode
     add a3ba853  [FLINK-20783][table-planner-blink] Introduce BatchPhysicalSortMergeJoin, and make BatchExecSortMergeJoin only extended from ExecNode
     add a34552e  [FLINK-20783][table-planner-blink] Use SortSpec in SortCodeGenerator and ComparatorCodeGenerator.

No new revisions were added by this update.

Summary of changes:
 .../plan/nodes/exec/batch/BatchExecHashJoin.java   | 239 +++++++++++++++++++++
 .../nodes/exec/batch/BatchExecNestedLoopJoin.java  | 122 +++++++++++
 .../plan/nodes/exec/batch/BatchExecRank.java       |  21 +-
 .../plan/nodes/exec/batch/BatchExecSort.java       |  17 +-
 .../plan/nodes/exec/batch/BatchExecSortLimit.java  |   7 +-
 .../nodes/exec/batch/BatchExecSortMergeJoin.java   | 173 +++++++++++++++
 .../plan/nodes/exec/stream/StreamExecRank.java     |  16 +-
 .../plan/nodes/exec/stream/StreamExecSort.java     |   7 +-
 .../nodes/exec/stream/StreamExecTemporalSort.java  |  14 +-
 .../plan/nodes/exec/utils/ExecNodeUtil.java        |   1 -
 .../planner/plan/nodes/exec/utils/SortSpec.java    |   5 +
 .../table/planner/codegen/GenerateUtils.scala      |  63 +++++-
 .../codegen/agg/batch/HashAggCodeGenHelper.scala   |   9 +-
 .../codegen/sort/ComparatorCodeGenerator.scala     |  21 +-
 .../planner/codegen/sort/SortCodeGenerator.scala   |  38 ++--
 .../physical/batch/BatchExecOverAggregate.scala    |  10 +-
 ...cHashJoin.scala => BatchPhysicalHashJoin.scala} | 136 ++++--------
 ...cJoinBase.scala => BatchPhysicalJoinBase.scala} |   5 +-
 ...oin.scala => BatchPhysicalNestedLoopJoin.scala} |  71 ++----
 ...Join.scala => BatchPhysicalSortMergeJoin.scala} | 102 ++-------
 .../nodes/physical/stream/StreamExecMatch.scala    |  10 +-
 .../planner/plan/rules/FlinkBatchRuleSets.scala    |   6 +-
 .../batch/BatchExecNestedLoopJoinRuleBase.scala    |   4 +-
 .../batch/BatchExecOverAggregateRule.scala         |  17 +-
 .../batch/BatchExecSingleRowJoinRule.scala         |   4 +-
 ...nRule.scala => BatchPhysicalHashJoinRule.scala} |  14 +-
 ...scala => BatchPhysicalNestedLoopJoinRule.scala} |  12 +-
 ....scala => BatchPhysicalSortMergeJoinRule.scala} |  16 +-
 .../flink/table/planner/plan/utils/JoinUtil.scala  |  21 +-
 .../planner/plan/utils/OverAggregateUtil.scala     |   2 +-
 .../flink/table/planner/plan/utils/SortUtil.scala  |  30 +--
 .../planner/codegen/SortCodeGeneratorTest.java     |  99 ++++-----
 .../plan/batch/sql/RemoveCollationTest.scala       |   4 +-
 .../planner/plan/batch/sql/RemoveShuffleTest.scala |   8 +-
 .../planner/plan/batch/sql/SubplanReuseTest.scala  |   4 +-
 .../flink/table/data/util/DataFormatTestUtil.java  |   8 +-
 36 files changed, 855 insertions(+), 481 deletions(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecHashJoin.java
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecNestedLoopJoin.java
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSortMergeJoin.java
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecHashJoin.scala => BatchPhysicalHashJoin.scala} (66%)
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecJoinBase.scala => BatchPhysicalJoinBase.scala} (98%)
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecNestedLoopJoin.scala => BatchPhysicalNestedLoopJoin.scala} (70%)
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecSortMergeJoin.scala => BatchPhysicalSortMergeJoin.scala} (64%)
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/{BatchExecHashJoinRule.scala => BatchPhysicalHashJoinRule.scala} (96%)
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/{BatchExecNestedLoopJoinRule.scala => BatchPhysicalNestedLoopJoinRule.scala} (91%)
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/{BatchExecSortMergeJoinRule.scala => BatchPhysicalSortMergeJoinRule.scala} (93%)