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 e8d6b29 [FLINK-20371][docs] Add docs for outer interval joins
add deb9e6e [FLINK-20436][table-planner-blink] Simplify ExecNode: Remove
"Planner" type parameter & Remove the default implementation into ExecNodeBase
No new revisions were added by this update.
Summary of changes:
.../connectors/hive/HiveTableSourceITCase.java | 3 +-
.../exec/AbstractExecNodeExactlyOnceVisitor.java | 8 +--
.../planner/plan/nodes/exec/ExecNodeVisitor.java | 2 +-
.../plan/nodes/exec/ExecNodeVisitorImpl.java | 4 +-
.../planner/plan/nodes/process/DAGProcessor.java | 2 +-
.../plan/processors/DeadlockBreakupProcessor.java | 2 +-
.../MultipleInputNodeCreationProcessor.java | 57 ++++++++-------
.../processors/utils/InputOrderCalculator.java | 44 ++++++------
.../utils/InputPriorityConflictResolver.java | 20 +++---
.../utils/InputPriorityGraphGenerator.java | 34 ++++-----
.../plan/processors/utils/TopologyGraph.java | 32 ++++-----
.../table/planner/delegation/BatchPlanner.scala | 4 +-
.../table/planner/delegation/PlannerBase.scala | 6 +-
.../table/planner/delegation/StreamPlanner.scala | 2 +-
.../planner/plan/nodes/exec/BatchExecNode.scala | 2 +-
.../table/planner/plan/nodes/exec/ExecNode.scala | 44 ++----------
.../planner/plan/nodes/exec/ExecNodeBase.scala | 81 ++++++++++++++++++++++
.../planner/plan/nodes/exec/StreamExecNode.scala | 2 +-
.../batch/BatchExecBoundedStreamScan.scala | 4 +-
.../nodes/physical/batch/BatchExecCalcBase.scala | 7 +-
.../nodes/physical/batch/BatchExecCorrelate.scala | 2 +-
.../physical/batch/BatchExecCorrelateBase.scala | 7 +-
.../nodes/physical/batch/BatchExecExchange.scala | 6 +-
.../nodes/physical/batch/BatchExecExpand.scala | 6 +-
.../physical/batch/BatchExecHashAggregate.scala | 2 +-
.../batch/BatchExecHashAggregateBase.scala | 6 +-
.../nodes/physical/batch/BatchExecHashJoin.scala | 6 +-
.../batch/BatchExecHashWindowAggregateBase.scala | 8 +--
.../nodes/physical/batch/BatchExecLegacySink.scala | 6 +-
.../batch/BatchExecLegacyTableSourceScan.scala | 4 +-
.../plan/nodes/physical/batch/BatchExecLimit.scala | 6 +-
.../batch/BatchExecLocalHashAggregate.scala | 2 +-
.../batch/BatchExecLocalSortAggregate.scala | 2 +-
.../nodes/physical/batch/BatchExecLookupJoin.scala | 6 +-
.../physical/batch/BatchExecMultipleInput.scala | 6 +-
.../physical/batch/BatchExecNestedLoopJoin.scala | 6 +-
.../physical/batch/BatchExecOverAggregate.scala | 2 +-
.../batch/BatchExecOverAggregateBase.scala | 7 +-
.../physical/batch/BatchExecPythonCorrelate.scala | 3 +-
.../batch/BatchExecPythonGroupAggregate.scala | 6 +-
.../BatchExecPythonGroupWindowAggregate.scala | 6 +-
.../plan/nodes/physical/batch/BatchExecRank.scala | 6 +-
.../plan/nodes/physical/batch/BatchExecSink.scala | 6 +-
.../plan/nodes/physical/batch/BatchExecSort.scala | 6 +-
.../physical/batch/BatchExecSortAggregate.scala | 2 +-
.../batch/BatchExecSortAggregateBase.scala | 6 +-
.../nodes/physical/batch/BatchExecSortLimit.scala | 6 +-
.../physical/batch/BatchExecSortMergeJoin.scala | 6 +-
.../batch/BatchExecSortWindowAggregate.scala | 2 +-
.../batch/BatchExecSortWindowAggregateBase.scala | 6 +-
.../physical/batch/BatchExecTableSourceScan.scala | 4 +-
.../plan/nodes/physical/batch/BatchExecUnion.scala | 6 +-
.../nodes/physical/batch/BatchExecValues.scala | 4 +-
.../nodes/physical/stream/StreamExecCalcBase.scala | 16 ++---
.../stream/StreamExecChangelogNormalize.scala | 13 ++--
.../physical/stream/StreamExecCorrelate.scala | 2 +-
.../physical/stream/StreamExecCorrelateBase.scala | 7 +-
.../physical/stream/StreamExecDataStreamScan.scala | 4 +-
.../physical/stream/StreamExecDeduplicate.scala | 6 +-
.../stream/StreamExecDropUpdateBefore.scala | 6 +-
.../nodes/physical/stream/StreamExecExchange.scala | 6 +-
.../nodes/physical/stream/StreamExecExpand.scala | 6 +-
.../stream/StreamExecGlobalGroupAggregate.scala | 6 +-
.../physical/stream/StreamExecGroupAggregate.scala | 7 +-
.../stream/StreamExecGroupTableAggregate.scala | 6 +-
.../stream/StreamExecGroupWindowAggregate.scala | 2 +-
.../StreamExecGroupWindowAggregateBase.scala | 6 +-
.../StreamExecGroupWindowTableAggregate.scala | 9 +--
.../StreamExecIncrementalGroupAggregate.scala | 6 +-
.../physical/stream/StreamExecIntervalJoin.scala | 6 +-
.../nodes/physical/stream/StreamExecJoin.scala | 6 +-
.../physical/stream/StreamExecLegacySink.scala | 6 +-
.../stream/StreamExecLegacyTableSourceScan.scala | 6 +-
.../nodes/physical/stream/StreamExecLimit.scala | 6 +-
.../stream/StreamExecLocalGroupAggregate.scala | 6 +-
.../physical/stream/StreamExecLookupJoin.scala | 6 +-
.../nodes/physical/stream/StreamExecMatch.scala | 6 +-
.../stream/StreamExecMiniBatchAssigner.scala | 6 +-
.../physical/stream/StreamExecMultipleInput.scala | 6 +-
.../physical/stream/StreamExecOverAggregate.scala | 2 +-
.../stream/StreamExecOverAggregateBase.scala | 7 +-
.../physical/stream/StreamExecPythonCalc.scala | 1 +
.../stream/StreamExecPythonCorrelate.scala | 1 +
.../stream/StreamExecPythonGroupAggregate.scala | 20 +++---
.../nodes/physical/stream/StreamExecRank.scala | 6 +-
.../nodes/physical/stream/StreamExecSink.scala | 6 +-
.../nodes/physical/stream/StreamExecSort.scala | 6 +-
.../physical/stream/StreamExecSortLimit.scala | 6 +-
.../stream/StreamExecTableSourceScan.scala | 7 +-
.../physical/stream/StreamExecTemporalJoin.scala | 8 ++-
.../physical/stream/StreamExecTemporalSort.scala | 6 +-
.../nodes/physical/stream/StreamExecUnion.scala | 6 +-
.../nodes/physical/stream/StreamExecValues.scala | 6 +-
.../stream/StreamExecWatermarkAssigner.scala | 6 +-
.../planner/plan/utils/ExecNodePlanDumper.scala | 46 ++++++------
.../MultipleInputNodeCreationProcessorTest.java | 2 +-
.../processors/utils/InputOrderCalculatorTest.java | 6 +-
.../utils/InputPriorityConflictResolverTest.java | 6 +-
.../utils/InputPriorityGraphGeneratorTest.java | 10 +--
.../plan/processors/utils/TopologyGraphTest.java | 6 +-
.../plan/nodes/exec/TestingBatchExecNode.scala | 12 ++--
.../flink/table/planner/utils/TableTestBase.scala | 2 +-
102 files changed, 463 insertions(+), 414 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeBase.scala
