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 f44b383 [FLINK-20705][table-planner-blink] Introduce
BatchPhysicalValues, and make BatchExecValues only extended from ExecNode
add 0287560 [FLINK-20707][table-planner-blink] Introduce
StreamPhysicalExpand, and make StreamExecExpand only extended from ExecNode
add 4fbffb6 [FLINK-20707][table-planner-blink] Introduce
BatchPhysicalExpand, and make BatchExecExpand only extended from ExecNode
No new revisions were added by this update.
Summary of changes:
.../{BatchExecCalc.java => BatchExecExpand.java} | 17 ++--
.../{CommonExecCalc.java => CommonExecExpand.java} | 51 ++++-------
.../{StreamExecCalc.java => StreamExecExpand.java} | 17 ++--
.../planner/codegen/ExpandCodeGenerator.scala | 2 -
.../nodes/physical/batch/BatchExecExpand.scala | 100 ---------------------
...sicalValues.scala => BatchPhysicalExpand.scala} | 42 +++++----
.../nodes/physical/stream/StreamExecExpand.scala | 90 -------------------
...ysicalCalc.scala => StreamPhysicalExpand.scala} | 35 +++++---
.../FlinkChangelogModeInferenceProgram.scala | 4 +-
.../planner/plan/rules/FlinkBatchRuleSets.scala | 2 +-
.../planner/plan/rules/FlinkStreamRuleSets.scala | 2 +-
...andRule.scala => BatchPhysicalExpandRule.scala} | 14 +--
.../physical/batch/EnforceLocalAggRuleBase.scala | 8 +-
.../physical/batch/EnforceLocalHashAggRule.scala | 8 +-
.../physical/batch/EnforceLocalSortAggRule.scala | 8 +-
...ndRule.scala => StreamPhysicalExpandRule.scala} | 14 +--
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 4 +-
17 files changed, 115 insertions(+), 303 deletions(-)
copy
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/{BatchExecCalc.java
=> BatchExecExpand.java} (76%)
copy
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/{CommonExecCalc.java
=> CommonExecExpand.java} (65%)
copy
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{StreamExecCalc.java
=> StreamExecExpand.java} (75%)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecExpand.scala
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchPhysicalValues.scala
=> BatchPhysicalExpand.scala} (65%)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecExpand.scala
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamPhysicalCalc.scala
=> StreamPhysicalExpand.scala} (66%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/{BatchExecExpandRule.scala
=> BatchPhysicalExpandRule.scala} (86%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecExpandRule.scala
=> StreamPhysicalExpandRule.scala} (86%)
