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 a046ee8 [FLINK-20213][fs-connector] Partition commit is delayed when
records keep coming
add b510e74 [FLINK-20608][table-planner-blink] Introduce
StreamPhysicalLegacyTableSourceScan, and make StreamExecLegacyTableSourceScan
only extended from ExecNode
add 55e749c [FLINK-20608][table-planner-blink] Introduce
BatchPhysicalLegacyTableSourceScan, and make BatchExecLegacyTableSourceScan
only extended from
No new revisions were added by this update.
Summary of changes:
.../exec/batch/BatchExecLegacyTableSourceScan.java | 133 +++++++++++
.../common/CommonExecLegacyTableSourceScan.java | 94 ++++++++
.../stream/StreamExecLegacyTableSourceScan.java | 252 ++++++++++++++++++++
.../batch/BatchExecBoundedStreamScan.scala | 6 +-
.../batch/BatchExecLegacyTableSourceScan.scala | 174 --------------
...la => BatchPhysicalLegacyTableSourceScan.scala} | 20 +-
.../CommonPhysicalLegacyTableSourceScan.scala} | 34 +--
.../physical/stream/StreamExecDataStreamScan.scala | 6 +-
.../stream/StreamExecLegacyTableSourceScan.scala | 257 ---------------------
...a => StreamPhysicalLegacyTableSourceScan.scala} | 23 +-
.../FlinkChangelogModeInferenceProgram.scala | 4 +-
.../table/planner/plan/reuse/SubplanReuser.scala | 5 +-
.../planner/plan/rules/FlinkBatchRuleSets.scala | 2 +-
.../planner/plan/rules/FlinkStreamRuleSets.scala | 2 +-
...> BatchPhysicalLegacyTableSourceScanRule.scala} | 17 +-
.../physical/common/CommonLookupJoinRule.scala | 7 +-
.../stream/MiniBatchIntervalInferRule.scala | 4 +-
... StreamPhysicalLegacyTableSourceScanRule.scala} | 19 +-
.../flink/table/planner/plan/utils/ScanUtil.scala | 22 +-
19 files changed, 548 insertions(+), 533 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecLegacyTableSourceScan.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecLegacyTableSourceScan.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecLegacyTableSourceScan.java
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecLegacyTableSourceScan.scala
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchPhysicalTableSourceScan.scala
=> BatchPhysicalLegacyTableSourceScan.scala} (78%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/{PhysicalLegacyTableSourceScan.scala
=> common/CommonPhysicalLegacyTableSourceScan.scala} (57%)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecLegacyTableSourceScan.scala
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamPhysicalTableSourceScan.scala
=> StreamPhysicalLegacyTableSourceScan.scala} (75%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/{BatchExecLegacyTableSourceScanRule.scala
=> BatchPhysicalLegacyTableSourceScanRule.scala} (85%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecLegacyTableSourceScanRule.scala
=> StreamPhysicalLegacyTableSourceScanRule.scala} (83%)
