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 e10e548 [FLINK-20464] Some Table examples are not built correctly
add af807df [FLINK-20437][table-planner-blink] Move the utility methods
in ExecNode into ExecNodeUtil
add 9365b5d [FLINK-20437][table-planner-blink] Port ExecNode to Java
No new revisions were added by this update.
Summary of changes:
.../table/planner/plan/nodes/exec/ExecNode.java | 74 +++++++++++
.../plan/nodes/exec/utils/ExecNodeUtil.java | 89 +++++++++++++
.../planner/codegen/CorrelateCodeGenerator.scala | 14 ++-
.../plan/nodes/common/CommonLookupJoin.scala | 7 +-
.../table/planner/plan/nodes/exec/ExecNode.scala | 137 ---------------------
.../plan/nodes/physical/batch/BatchExecCalc.scala | 7 +-
.../nodes/physical/batch/BatchExecExpand.scala | 6 +-
.../batch/BatchExecHashAggregateBase.scala | 3 +-
.../nodes/physical/batch/BatchExecHashJoin.scala | 3 +-
.../batch/BatchExecHashWindowAggregateBase.scala | 3 +-
.../nodes/physical/batch/BatchExecLegacySink.scala | 6 +-
.../batch/BatchExecLegacyTableSourceScan.scala | 3 +-
.../plan/nodes/physical/batch/BatchExecLimit.scala | 6 +-
.../physical/batch/BatchExecMultipleInput.scala | 3 +-
.../physical/batch/BatchExecNestedLoopJoin.scala | 3 +-
.../physical/batch/BatchExecOverAggregate.scala | 4 +-
.../plan/nodes/physical/batch/BatchExecRank.scala | 6 +-
.../plan/nodes/physical/batch/BatchExecSort.scala | 3 +-
.../batch/BatchExecSortAggregateBase.scala | 6 +-
.../nodes/physical/batch/BatchExecSortLimit.scala | 6 +-
.../physical/batch/BatchExecSortMergeJoin.scala | 3 +-
.../batch/BatchExecSortWindowAggregateBase.scala | 6 +-
.../physical/batch/BatchExecTableSourceScan.scala | 2 +-
.../plan/nodes/physical/batch/BatchExecUnion.scala | 2 +-
.../nodes/physical/batch/BatchExecValues.scala | 2 +-
.../flink/table/planner/plan/utils/ScanUtil.scala | 8 +-
26 files changed, 232 insertions(+), 180 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNode.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/utils/ExecNodeUtil.java
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/exec/ExecNode.scala
