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 4fbffb6 [FLINK-20707][table-planner-blink] Introduce
BatchPhysicalExpand, and make BatchExecExpand only extended from ExecNode
add 2eb84aa [FLINK-20708][table-planner-blink] Introduce
StreamPhysicalDropUpdateBefore, and make StreamExecDropUpdateBefore only
extended from ExecNode
No new revisions were added by this update.
Summary of changes:
.../StreamExecDropUpdateBefore.java} | 51 ++++++----------------
.../plan/metadata/FlinkRelMdColumnUniqueness.scala | 2 +-
.../metadata/FlinkRelMdModifiedMonotonicity.scala | 2 +-
.../plan/metadata/FlinkRelMdUniqueKeys.scala | 2 +-
....scala => StreamPhysicalDropUpdateBefore.scala} | 42 ++++++------------
.../FlinkChangelogModeInferenceProgram.scala | 2 +-
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 2 +-
7 files changed, 32 insertions(+), 71 deletions(-)
copy
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/{common/CommonExecExpand.java
=> stream/StreamExecDropUpdateBefore.java} (52%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecDropUpdateBefore.scala
=> StreamPhysicalDropUpdateBefore.scala} (60%)
