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 2eb84aa [FLINK-20708][table-planner-blink] Introduce
StreamPhysicalDropUpdateBefore, and make StreamExecDropUpdateBefore only
extended from ExecNode
add 8da6052 [FLINK-20709][table-planner-blink] Introduce
StreamPhysicalMiniBatchAssigner, and make StreamExecMiniBatchAssigner only
extended from ExecNode
No new revisions were added by this update.
Summary of changes:
.../exec/stream/StreamExecMiniBatchAssigner.java | 86 ++++++++++++++++++
.../metadata/FlinkRelMdModifiedMonotonicity.scala | 2 +-
.../stream/StreamExecMiniBatchAssigner.scala | 101 ---------------------
...scala => StreamPhysicalMiniBatchAssigner.scala} | 47 +++++-----
.../FlinkChangelogModeInferenceProgram.scala | 6 +-
.../stream/MiniBatchIntervalInferRule.scala | 8 +-
6 files changed, 117 insertions(+), 133 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecMiniBatchAssigner.java
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecMiniBatchAssigner.scala
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamPhysicalChangelogNormalize.scala
=> StreamPhysicalMiniBatchAssigner.scala} (58%)
