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 55e749c [FLINK-20608][table-planner-blink] Introduce
BatchPhysicalLegacyTableSourceScan, and make BatchExecLegacyTableSourceScan
only extended from
add 274a417 [FLINK-20609][table-planner-blink] Introduce
StreamPhysicalDataStreamScan, and make StreamExecDataStreamScan only extended
from ExecNode
add e2feafa [FLINK-20609][table-planner-blink] Introduce
BatchPhysicalDataStreamScan, and make BatchExecDataStreamScan only extended
from ExecNode
No new revisions were added by this update.
Summary of changes:
.../exec/batch/BatchExecBoundedStreamScan.java | 85 ++++++++++++
.../MultipleInputNodeCreationProcessor.java | 8 +-
.../nodes/exec/processor/utils/TopologyGraph.java | 6 +-
.../exec/stream/StreamExecDataStreamScan.java | 140 ++++++++++++++++++++
.../metadata/FlinkRelMdModifiedMonotonicity.scala | 7 +-
....scala => BatchPhysicalBoundedStreamScan.scala} | 60 +++------
.../physical/stream/StreamExecDataStreamScan.scala | 146 ---------------------
...an.scala => StreamPhysicalDataStreamScan.scala} | 41 ++++--
.../StreamCommonSubGraphBasedOptimizer.scala | 4 +-
.../FlinkChangelogModeInferenceProgram.scala | 4 +-
.../planner/plan/rules/FlinkBatchRuleSets.scala | 2 +-
.../planner/plan/rules/FlinkStreamRuleSets.scala | 2 +-
...la => BatchPhysicalBoundedStreamScanRule.scala} | 14 +-
.../stream/MiniBatchIntervalInferRule.scala | 4 +-
...cala => StreamPhysicalDataStreamScanRule.scala} | 14 +-
.../planner/match/PatternTranslatorTestBase.scala | 6 +-
.../plan/metadata/FlinkRelMdDistributionTest.scala | 8 +-
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 30 ++---
18 files changed, 326 insertions(+), 255 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecBoundedStreamScan.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecDataStreamScan.java
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecBoundedStreamScan.scala
=> BatchPhysicalBoundedStreamScan.scala} (55%)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecDataStreamScan.scala
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamPhysicalLegacyTableSourceScan.scala
=> StreamPhysicalDataStreamScan.scala} (61%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/{BatchExecBoundedStreamScanRule.scala
=> BatchPhysicalBoundedStreamScanRule.scala} (85%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecDataStreamScanRule.scala
=> StreamPhysicalDataStreamScanRule.scala} (87%)
