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/21 11:44:25 UTC
[flink] branch master updated (d42c333 -> 9525a6c)

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 d42c333  [FLINK-20654][tests] Temporarily ignore UnalignedCheckpointITCase
     add d4cf110  [FLINK-20516][table-planner-blink] Introduce StreamPhysicalTableSourceScan, and make StreamExecTableSourceScan only extended from ExecNode
     add 9525a6c  [FLINK-20516][table-planner-blink] Introduce BatchPhysicalTableSourceScan, and make BatchExecTableSourceScan only extended from ExecNode

No new revisions were added by this update.

Summary of changes:
 .../nodes/exec/batch/BatchExecTableSourceScan.java |  66 ++++++++++++++
 .../exec/common/CommonExecTableSourceScan.java     |  77 ++++++++++++++++
 .../MultipleInputNodeCreationProcessor.java        |   4 +-
 .../exec/stream/StreamExecTableSourceScan.java     |  62 +++++++++++++
 .../metadata/FlinkRelMdModifiedMonotonicity.scala  |   2 +-
 .../common/CommonPhysicalTableSourceScan.scala     | 101 ---------------------
 ...an.scala => BatchPhysicalTableSourceScan.scala} |  47 +++-------
 .../common/CommonPhysicalTableSourceScan.scala}    |  43 ++++-----
 ...n.scala => StreamPhysicalTableSourceScan.scala} |  46 +++-------
 .../FlinkChangelogModeInferenceProgram.scala       |   4 +-
 .../table/planner/plan/reuse/SubplanReuser.scala   |   2 +-
 .../planner/plan/rules/FlinkBatchRuleSets.scala    |   2 +-
 .../planner/plan/rules/FlinkStreamRuleSets.scala   |   2 +-
 ...cala => BatchPhysicalTableSourceScanRule.scala} |  14 +--
 .../physical/common/CommonLookupJoinRule.scala     |   3 +-
 .../stream/MiniBatchIntervalInferRule.scala        |   5 +-
 ...ala => StreamPhysicalTableSourceScanRule.scala} |  15 ++-
 17 files changed, 278 insertions(+), 217 deletions(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecTableSourceScan.java
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecTableSourceScan.java
 delete mode 100644 flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalTableSourceScan.scala
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecTableSourceScan.scala => BatchPhysicalTableSourceScan.scala} (50%)
 copy flink-table/{flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/Sink.scala => flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/common/CommonPhysicalTableSourceScan.scala} (50%)
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecTableSourceScan.scala => StreamPhysicalTableSourceScan.scala} (52%)
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/{BatchExecTableSourceScanRule.scala => BatchPhysicalTableSourceScanRule.scala} (90%)
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecTableSourceScanRule.scala => StreamPhysicalTableSourceScanRule.scala} (92%)