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 dc0b143 [FLINK-20782][table-planner-blink] Introduce
BatchPhysicalRank, and make BatchExecRank only extended from ExecNode
add 6c75072 [FLINK-20766][table-planner-blink] Introduce
StreamPhysicalSort, and make StreamExecSort only extended from ExecNode
add bc782b6 [FLINK-20766][table-planner-blink] Introduce
StreamPhysicalSortLimit, and make StreamExecSortLimit only extends from
ExecNode.
add 91f93d9 [FLINK-20766][table-planner-blink] Introduce
StreamPhysicalTemporalSort, and make StreamExecTemporalSort only extended from
ExecNode.
add ae796bb [FLINK-20766][table-planner-blink] Introduce
BatchPhysicalSort, and make BatchExeSort only extended from ExecNode
add 7668e4e [FLINK-20766][table-planner-blink] Introduce
BatchPhysicalSortLimit, and make BatchExecSortLimit only extended from ExecNode
No new revisions were added by this update.
Summary of changes:
.../plan/nodes/exec/batch/BatchExecSort.java | 100 ++++++++++
.../plan/nodes/exec/batch/BatchExecSortLimit.java | 105 ++++++++++
.../plan/nodes/exec/stream/StreamExecLimit.java | 12 +-
.../plan/nodes/exec/stream/StreamExecRank.java | 40 ++--
.../plan/nodes/exec/stream/StreamExecSort.java | 104 ++++++++++
...reamExecLimit.java => StreamExecSortLimit.java} | 32 ++--
.../nodes/exec/stream/StreamExecTemporalSort.java | 170 +++++++++++++++++
.../plan/nodes/exec/utils/PartitionSpec.java | 38 ++++
.../planner/plan/nodes/exec/utils/SortSpec.java | 136 +++++++++++++
.../plan/metadata/FlinkRelMdDistribution.scala | 4 +-
.../plan/nodes/logical/FlinkLogicalSort.scala | 4 +-
...BatchExecSort.scala => BatchPhysicalSort.scala} | 65 ++-----
...ortLimit.scala => BatchPhysicalSortLimit.scala} | 67 ++-----
.../nodes/physical/stream/StreamExecSort.scala | 126 ------------
.../physical/stream/StreamExecSortLimit.scala | 211 ---------------------
.../physical/stream/StreamExecTemporalSort.scala | 179 -----------------
.../nodes/physical/stream/StreamPhysicalRank.scala | 11 +-
.../nodes/physical/stream/StreamPhysicalSort.scala | 83 ++++++++
.../physical/stream/StreamPhysicalSortLimit.scala | 103 ++++++++++
.../stream/StreamPhysicalTemporalSort.scala | 71 +++++++
.../FlinkChangelogModeInferenceProgram.scala | 12 +-
.../planner/plan/rules/FlinkBatchRuleSets.scala | 4 +-
.../planner/plan/rules/FlinkStreamRuleSets.scala | 6 +-
.../rules/physical/FlinkExpandConversionRule.scala | 4 +-
...Rule.scala => BatchPhysicalSortLimitRule.scala} | 20 +-
...cSortRule.scala => BatchPhysicalSortRule.scala} | 18 +-
.../physical/batch/EnforceLocalSortAggRule.scala | 8 +-
.../batch/RemoveRedundantLocalSortAggRule.scala | 4 +-
...ule.scala => StreamPhysicalSortLimitRule.scala} | 14 +-
...SortRule.scala => StreamPhysicalSortRule.scala} | 16 +-
....scala => StreamPhysicalTemporalSortRule.scala} | 20 +-
.../flink/table/planner/plan/utils/SortUtil.scala | 10 +
.../plan/batch/sql/RemoveCollationTest.scala | 6 +-
.../planner/plan/batch/sql/SortLimitTest.scala | 22 +--
.../table/planner/plan/batch/sql/SortTest.scala | 12 +-
.../planner/plan/batch/sql/SubplanReuseTest.scala | 4 +-
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 18 +-
.../planner/runtime/batch/sql/CalcITCase.scala | 4 +-
.../planner/runtime/stream/sql/SortITCase.scala | 14 +-
.../table/runtime/operators/sort/SortOperator.java | 6 +-
40 files changed, 1100 insertions(+), 783 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSort.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSortLimit.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecSort.java
copy
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{StreamExecLimit.java
=> StreamExecSortLimit.java} (74%)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecTemporalSort.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/utils/PartitionSpec.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/utils/SortSpec.java
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecSort.scala
=> BatchPhysicalSort.scala} (54%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecSortLimit.scala
=> BatchPhysicalSortLimit.scala} (62%)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecSort.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecSortLimit.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTemporalSort.scala
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalSort.scala
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalSortLimit.scala
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalTemporalSort.scala
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/{BatchExecSortLimitRule.scala
=> BatchPhysicalSortLimitRule.scala} (91%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/{BatchExecSortRule.scala
=> BatchPhysicalSortRule.scala} (89%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecSortLimitRule.scala
=> StreamPhysicalSortLimitRule.scala} (90%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecSortRule.scala
=> StreamPhysicalSortRule.scala} (88%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecTemporalSortRule.scala
=> StreamPhysicalTemporalSortRule.scala} (88%)
