This is an automated email from the ASF dual-hosted git repository. jingzhang pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 35e90eb [FLINK-24325][tests] Update Elasticsearch CI tests add f37f85e [FLINK-21327][table-planner-blink] Support window TVF in batch mode (#17666) No new revisions were added by this update. Summary of changes: .../functions/sql/SqlWindowTableFunction.java | 27 +- .../planner/plan/logical/WindowingStrategy.java | 5 + .../exec/batch/BatchExecWindowTableFunction.java | 46 ++ .../exec/common/CommonExecWindowTableFunction.java | 96 +++ .../exec/stream/StreamExecWindowTableFunction.java | 83 +-- .../planner/plan/trait/RelWindowProperties.java | 3 +- .../plan/utils/WindowTableFunctionUtil.java | 76 ++ .../common/CommonPhysicalWindowTableFunction.scala | 70 ++ .../BatchPhysicalWindowTableFunction.scala} | 54 +- .../stream/StreamPhysicalWindowTableFunction.scala | 19 +- .../planner/plan/rules/FlinkBatchRuleSets.scala | 6 +- .../BatchPhysicalWindowTableFunctionRule.scala} | 25 +- .../StreamPhysicalWindowTableFunctionRule.scala | 8 +- .../table/planner/plan/utils/WindowUtil.scala | 15 +- .../plan/batch/sql/WindowTableFunctionTest.xml | 270 +++++++ .../plan/batch/sql/WindowTableFunctionTest.scala | 210 ++++++ .../plan/metadata/FlinkRelMdHandlerTestBase.scala | 75 +- .../plan/metadata/FlinkRelMdRowCountTest.scala | 13 + .../plan/stream/sql/WindowTableFunctionTest.scala | 7 +- .../batch/sql/WindowTableFunctionITCase.scala | 805 +++++++++++++++++++++ .../window/WindowTableFunctionOperator.java | 4 + 21 files changed, 1761 insertions(+), 156 deletions(-) create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecWindowTableFunction.java create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecWindowTableFunction.java create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/WindowTableFunctionUtil.java create mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalWindowTableFunction.scala copy flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/{stream/StreamPhysicalWindowTableFunction.scala => batch/BatchPhysicalWindowTableFunction.scala} (56%) copy flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/{stream/StreamPhysicalWindowTableFunctionRule.scala => batch/BatchPhysicalWindowTableFunctionRule.scala} (77%) create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/WindowTableFunctionTest.xml create mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/WindowTableFunctionTest.scala create mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/WindowTableFunctionITCase.scala