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 e2feafa [FLINK-20609][table-planner-blink] Introduce
BatchPhysicalDataStreamScan, and make BatchExecDataStreamScan only extended
from ExecNode
add 5cc3fdf [FLINK-20622][table-planner-blink] Introduce
StreamPhysicalChangelogNormalize, and make StreamExecChangelogNormalize only
extended from ExecNode
No new revisions were added by this update.
Summary of changes:
.../exec/stream/StreamExecChangelogNormalize.java | 115 +++++++++++++++++++
...arkAssignerChangelogNormalizeTransposeRule.java | 14 +--
.../plan/metadata/FlinkRelMdColumnUniqueness.scala | 2 +-
.../metadata/FlinkRelMdModifiedMonotonicity.scala | 2 +-
.../plan/metadata/FlinkRelMdUniqueKeys.scala | 2 +-
.../stream/StreamExecChangelogNormalize.scala | 127 ---------------------
...cala => StreamPhysicalChangelogNormalize.scala} | 48 +++++---
.../FlinkChangelogModeInferenceProgram.scala | 10 +-
.../stream/StreamPhysicalTableSourceScanRule.scala | 6 +-
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 2 +-
10 files changed, 167 insertions(+), 161 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecChangelogNormalize.java
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecChangelogNormalize.scala
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamPhysicalExchange.scala
=> StreamPhysicalChangelogNormalize.scala} (52%)
