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 313e20e [FLINK-20533][datadog] Add Histogram support
add dca86b8 [hotfix] StreamExecLegacySink should use getInputNodes to
translate the input node to transformation
add f945303 [FLINK-20513][table-planner-blink] Introduce
BatchPhysicalExchange, and make BatchExecExchange only extended from ExecNode
add 24d6065 [FLINK-20513][table-planner-blink] Introduce
StreamPhysicalExchange, and make StreamExecExchange only extended from ExecNode
No new revisions were added by this update.
Summary of changes:
.../plan/nodes/exec/ExecGraphGenerator.java | 72 +++++++-
.../plan/nodes/exec/batch/BatchExecExchange.java | 161 ++++++++++++++++
.../CommonExecExchange.java} | 16 +-
.../exec/processor/DeadlockBreakupProcessor.java | 3 +-
.../MultipleInputNodeCreationProcessor.java | 14 +-
.../utils/InputPriorityConflictResolver.java | 66 ++++---
.../plan/nodes/exec/stream/StreamExecExchange.java | 89 +++++++++
...arkAssignerChangelogNormalizeTransposeRule.java | 10 +-
.../plan/utils/RelDescriptionWriterImpl.java | 2 +-
.../table/planner/delegation/PlannerBase.scala | 2 +-
.../plan/nodes/common/CommonPhysicalSink.scala | 2 +-
.../nodes/physical/batch/BatchExecExchange.scala | 205 ---------------------
...TableScan.scala => BatchPhysicalExchange.scala} | 29 ++-
.../common/CommonPhysicalExchange.scala | 2 +-
.../nodes/physical/stream/StreamExecExchange.scala | 97 ----------
.../StreamExecIncrementalGroupAggregate.scala | 8 +-
.../physical/stream/StreamExecLegacySink.scala | 5 +-
...CalcBase.scala => StreamPhysicalExchange.scala} | 33 ++--
.../FlinkChangelogModeInferenceProgram.scala | 4 +-
.../rules/physical/FlinkExpandConversionRule.scala | 8 +-
.../physical/batch/BatchExecHashAggRule.scala | 4 +-
.../rules/physical/batch/BatchExecLimitRule.scala | 4 +-
.../rules/physical/batch/BatchExecRankRule.scala | 2 +-
.../physical/batch/BatchExecSortAggRule.scala | 4 +-
.../physical/batch/BatchExecSortLimitRule.scala | 4 +-
.../batch/BatchExecWindowAggregateRule.scala | 4 +-
.../physical/batch/EnforceLocalAggRuleBase.scala | 6 +-
.../physical/batch/EnforceLocalHashAggRule.scala | 4 +-
.../physical/batch/EnforceLocalSortAggRule.scala | 4 +-
.../physical/stream/IncrementalAggregateRule.scala | 8 +-
.../stream/TwoStageOptimizedAggregateRule.scala | 6 +-
.../planner/plan/utils/RelTreeWriterImpl.scala | 2 +
.../MultipleInputNodeCreationProcessorTest.java | 2 +-
.../utils/InputPriorityConflictResolverTest.java | 27 +--
.../planner/plan/batch/sql/RemoveCollationTest.xml | 2 +-
.../planner/plan/batch/sql/RemoveShuffleTest.xml | 2 +-
.../table/planner/plan/batch/sql/SortTest.xml | 4 +-
.../planner/match/PatternTranslatorTestBase.scala | 2 +-
.../plan/batch/sql/RemoveCollationTest.scala | 3 +-
.../table/planner/plan/batch/sql/SortTest.scala | 6 +-
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 66 +++----
.../plan/nodes/exec/TestingBatchExecNode.scala | 3 +
42 files changed, 513 insertions(+), 484 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecExchange.java
copy
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/{visitor/ExecNodeVisitor.java
=> common/CommonExecExchange.java} (75%)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecExchange.java
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecExchange.scala
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecIntermediateTableScan.scala
=> BatchPhysicalExchange.scala} (56%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/{
=> physical}/common/CommonPhysicalExchange.scala (98%)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecExchange.scala
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecCalcBase.scala
=> StreamPhysicalExchange.scala} (59%)
