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 cd6967c [FLINK-19681][network] Force priority for converted barriers
add 257e546 [FLINK-20610][table-planner-blink] Introduce
StreamPhysicalCalc & StreamPhysicalPythonCalc, and make StreamExecCalc &
StreamExecPythonCalc only extended from ExecNode
add a04af5f [FLINK-20610][table-planner-blink] Introduce
BatchPhysicalCalc & BatchPhysicalPythonCalc, and make BatchExecCalc &
BatchExecPythonCalc only extended from ExecNode
No new revisions were added by this update.
Summary of changes:
.../planner/plan/nodes/exec/ExecNodeBase.java | 10 +++
.../plan/nodes/exec/batch/BatchExecCalc.java | 59 +++++++++++++
.../plan/nodes/exec/common/CommonExecCalc.java | 86 +++++++++++++++++++
.../plan/nodes/exec/stream/StreamExecCalc.java | 59 +++++++++++++
...arkAssignerChangelogNormalizeTransposeRule.java | 8 +-
.../table/planner/codegen/CalcCodeGenerator.scala | 2 +-
.../batch/BatchExecPythonCalc.scala | 43 +++++-----
.../common/CommonExecPythonCalc.scala} | 11 +--
.../stream/StreamExecPythonCalc.scala | 43 +++++-----
.../plan/nodes/physical/batch/BatchExecCalc.scala | 79 -----------------
.../BatchPhysicalCalc.scala} | 33 +++++---
...cCalcBase.scala => BatchPhysicalCalcBase.scala} | 13 +--
...honCalc.scala => BatchPhysicalPythonCalc.scala} | 36 +++-----
.../nodes/physical/stream/StreamExecCalc.scala | 99 ----------------------
...ExecCalcBase.scala => StreamPhysicalCalc.scala} | 29 ++++---
...CalcBase.scala => StreamPhysicalCalcBase.scala} | 7 +-
...lcBase.scala => StreamPhysicalPythonCalc.scala} | 32 ++++---
.../FlinkChangelogModeInferenceProgram.scala | 4 +-
.../planner/plan/rules/FlinkBatchRuleSets.scala | 4 +-
.../planner/plan/rules/FlinkStreamRuleSets.scala | 4 +-
...cCalcRule.scala => BatchPhysicalCalcRule.scala} | 16 ++--
...ule.scala => BatchPhysicalPythonCalcRule.scala} | 16 ++--
...CalcRule.scala => StreamPhysicalCalcRule.scala} | 17 ++--
...le.scala => StreamPhysicalPythonCalcRule.scala} | 16 ++--
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 24 +++---
.../plan/metadata/FlinkRelMdSelectivityTest.scala | 4 +-
26 files changed, 393 insertions(+), 361 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecCalc.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecCalc.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecCalc.java
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/{physical
=> exec}/batch/BatchExecPythonCalc.scala (68%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/{common/CommonPythonCalc.scala
=> exec/common/CommonExecPythonCalc.scala} (92%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/{physical
=> exec}/stream/StreamExecPythonCalc.scala (69%)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecCalc.scala
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/{stream/StreamExecCalcBase.scala
=> batch/BatchPhysicalCalc.scala} (55%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecCalcBase.scala
=> BatchPhysicalCalcBase.scala} (91%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecPythonCalc.scala
=> BatchPhysicalPythonCalc.scala} (59%)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecCalc.scala
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecCalcBase.scala
=> StreamPhysicalCalc.scala} (62%)
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecCalcBase.scala
=> StreamPhysicalCalcBase.scala} (87%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecCalcBase.scala
=> StreamPhysicalPythonCalc.scala} (60%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/{BatchExecCalcRule.scala
=> BatchPhysicalCalcRule.scala} (86%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/{BatchExecPythonCalcRule.scala
=> BatchPhysicalPythonCalcRule.scala} (85%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecCalcRule.scala
=> StreamPhysicalCalcRule.scala} (86%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecPythonCalcRule.scala
=> StreamPhysicalPythonCalcRule.scala} (85%)
