You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ji...@apache.org on 2021/11/29 08:23:42 UTC
[flink] branch master updated (35e90eb -> f37f85e)

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