You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by go...@apache.org on 2020/12/22 02:50:44 UTC
[flink] branch master updated (55e749c -> e2feafa)

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%)