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 4ce5d03 [FLINK-20354] Rework standalone docs page
add d472159 [FLINK-20515][table-planner-blink] Move ExecNodePlanDumper
into `exec.utils` package
add 46f828f [FLINK-20515][table-planner-blink] Move ExecNode visitors
into `exec.visitor` package
add 0c5e8b5 [FLINK-20515][table-planner-blink] Move ExecNode processors
into `exec.processor` package
add 67b488d [FLINK-20515][table-planner-blink] Introduce new ExecNode
base classes
add ddd4e38 [FLINK-20515][table-planner-blink] Make
BatchExecMultipleInput extended only from BatchExecNode and port it to Java
add 6c886a4 [FLINK-20515][table-planner-blink] Make
StreamExecMultipleInput extended only from StreamExecNode and port it to Java
add 5088b8a [FLINK-20515][table-planner-blink] Remove MultipleInputRel
No new revisions were added by this update.
Summary of changes:
.../table/planner/plan/nodes/exec/ExecNode.java | 1 +
.../planner/plan/nodes/exec/ExecNodeBase.java | 110 +++++++++++++++++++
.../nodes/exec/batch/BatchExecMultipleInput.java | 119 +++++++++++++++++++++
.../batch/BatchExecNode.java} | 24 +++--
.../processor}/DAGProcessContext.java | 2 +-
.../{process => exec/processor}/DAGProcessor.java | 2 +-
.../exec/processor}/DeadlockBreakupProcessor.java | 13 ++-
.../MultipleInputNodeCreationProcessor.java | 72 ++++++-------
.../processor}/utils/InputOrderCalculator.java | 4 +-
.../utils/InputPriorityConflictResolver.java | 4 +-
.../utils/InputPriorityGraphGenerator.java | 7 +-
.../exec/processor}/utils/TopologyGraph.java | 4 +-
.../nodes/exec/stream/StreamExecMultipleInput.java | 77 +++++++++++++
.../stream/StreamExecNode.java} | 24 +++--
.../{ => nodes/exec}/utils/ExecNodePlanDumper.java | 6 +-
.../plan/nodes/exec/utils/ExecNodeUtil.java | 29 ++++-
.../AbstractExecNodeExactlyOnceVisitor.java | 6 +-
.../nodes/exec/{ => visitor}/ExecNodeVisitor.java | 4 +-
.../exec/{ => visitor}/ExecNodeVisitorImpl.java | 6 +-
.../table/planner/delegation/BatchPlanner.scala | 12 ++-
.../table/planner/delegation/StreamPlanner.scala | 7 +-
.../plan/metadata/FlinkRelMdUniqueKeys.scala | 9 +-
.../plan/nodes/exec/LegacyExecNodeBase.scala | 1 +
.../plan/nodes/physical/MultipleInputRel.scala | 70 ------------
.../nodes/physical/batch/BatchExecLegacySink.scala | 9 +-
.../physical/batch/BatchExecMultipleInput.scala | 106 ------------------
.../plan/nodes/physical/batch/BatchExecSink.scala | 8 +-
.../physical/stream/StreamExecLegacySink.scala | 7 +-
.../physical/stream/StreamExecMultipleInput.scala | 62 -----------
.../nodes/physical/stream/StreamExecSink.scala | 7 +-
.../MultipleInputNodeCreationProcessorTest.java | 3 +-
.../processor}/utils/InputOrderCalculatorTest.java | 2 +-
.../utils/InputPriorityConflictResolverTest.java | 2 +-
.../utils/InputPriorityGraphGeneratorTest.java | 2 +-
.../exec/processor}/utils/TopologyGraphTest.java | 2 +-
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 42 --------
.../plan/metadata/FlinkRelMdUniqueKeysTest.scala | 6 --
.../flink/table/planner/utils/TableTestBase.scala | 3 +-
38 files changed, 465 insertions(+), 409 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeBase.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecMultipleInput.java
copy
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/{process/DAGProcessor.java
=> exec/batch/BatchExecNode.java} (55%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/{process
=> exec/processor}/DAGProcessContext.java (95%)
copy
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/{process
=> exec/processor}/DAGProcessor.java (94%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/{processors
=> nodes/exec/processor}/DeadlockBreakupProcessor.java (80%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/{processors
=> nodes/exec/processor}/MultipleInputNodeCreationProcessor.java (91%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/{processors
=> nodes/exec/processor}/utils/InputOrderCalculator.java (97%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/{processors
=> nodes/exec/processor}/utils/InputPriorityConflictResolver.java (96%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/{processors
=> nodes/exec/processor}/utils/InputPriorityGraphGenerator.java (96%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/{processors
=> nodes/exec/processor}/utils/TopologyGraph.java (97%)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecMultipleInput.java
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/{process/DAGProcessor.java
=> exec/stream/StreamExecNode.java} (55%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/{
=> nodes/exec}/utils/ExecNodePlanDumper.java (98%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/{
=> visitor}/AbstractExecNodeExactlyOnceVisitor.java (88%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/{
=> visitor}/ExecNodeVisitor.java (88%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/{
=> visitor}/ExecNodeVisitorImpl.java (86%)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/MultipleInputRel.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecMultipleInput.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecMultipleInput.scala
rename
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/{processors
=> nodes/exec/processor}/MultipleInputNodeCreationProcessorTest.java (98%)
rename
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/{processors
=> nodes/exec/processor}/utils/InputOrderCalculatorTest.java (99%)
rename
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/{processors
=> nodes/exec/processor}/utils/InputPriorityConflictResolverTest.java (98%)
rename
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/{processors
=> nodes/exec/processor}/utils/InputPriorityGraphGeneratorTest.java (98%)
rename
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/{processors
=> nodes/exec/processor}/utils/TopologyGraphTest.java (98%)
