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 110a044 [FLINK-20745][table] Clean useless codes: Never push
calcProgram to correlate
add acbda63 [FLINK-20705][table-planner-blink] Introduce
StreamPhysicalValues, and make StreamExecValues only extended from ExecNode
add f44b383 [FLINK-20705][table-planner-blink] Introduce
BatchPhysicalValues, and make BatchExecValues only extended from ExecNode
No new revisions were added by this update.
Summary of changes:
.../{BatchExecCalc.java => BatchExecValues.java} | 20 +++---
.../plan/nodes/exec/common/CommonExecValues.java | 60 ++++++++++++++++++
.../{StreamExecCalc.java => StreamExecValues.java} | 20 +++---
.../planner/codegen/ValuesCodeGenerator.scala | 12 ++--
...hExecValues.scala => BatchPhysicalValues.scala} | 39 ++++--------
.../nodes/physical/stream/StreamExecValues.scala | 71 ----------------------
...SourceScan.scala => StreamPhysicalValues.scala} | 38 ++++++------
.../FlinkChangelogModeInferenceProgram.scala | 4 +-
.../planner/plan/rules/FlinkBatchRuleSets.scala | 2 +-
.../planner/plan/rules/FlinkStreamRuleSets.scala | 2 +-
...atchPhysicalConstantTableFunctionScanRule.scala | 10 +--
...uesRule.scala => BatchPhysicalValuesRule.scala} | 14 ++---
...reamPhysicalConstantTableFunctionScanRule.scala | 8 +--
...esRule.scala => StreamPhysicalValuesRule.scala} | 14 ++---
14 files changed, 139 insertions(+), 175 deletions(-)
copy
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/{BatchExecCalc.java
=> BatchExecValues.java} (67%)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecValues.java
copy
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{StreamExecCalc.java
=> StreamExecValues.java} (67%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecValues.scala
=> BatchPhysicalValues.scala} (62%)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecValues.scala
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamPhysicalTableSourceScan.scala
=> StreamPhysicalValues.scala} (61%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/{BatchExecValuesRule.scala
=> BatchPhysicalValuesRule.scala} (84%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecValuesRule.scala
=> StreamPhysicalValuesRule.scala} (85%)
