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/12/29 09:17:41 UTC
[flink] branch master updated (6bab695 -> 9fce1be)
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 6bab695 [FLINK-25468] Copy SST files if they cannot be hard linked in RocksDBHandle.restoreInstanceDirectoryFromPath
add 9fce1be [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner (#17684)
No new revisions were added by this update.
Summary of changes:
.../exec/batch/BatchExecWindowTableFunction.java | 11 +
.../exec/common/CommonExecWindowTableFunction.java | 8 +-
.../exec/stream/StreamExecWindowTableFunction.java | 36 --
.../stream/SimplifyWindowTableFunctionRules.java | 348 ----------------
.../plan/utils/WindowTableFunctionUtil.java | 19 +-
.../stream/StreamPhysicalWindowTableFunction.scala | 24 +-
.../planner/plan/rules/FlinkStreamRuleSets.scala | 9 -
.../ExpandWindowTableFunctionTransposeRule.scala | 3 +-
.../StreamPhysicalWindowTableFunctionRule.scala | 3 +-
.../stream/WindowTableFunctionJsonPlanTest.java | 44 ++
...ase.java => WindowTableFunctionJsonITCase.java} | 17 +-
.../nodes/exec/operator/StreamOperatorNameTest.xml | 28 +-
.../testFollowedByWindowDeduplicate.out | 3 +-
.../testFollowedByWindowJoin.out | 6 +-
.../testFollowedByWindowRank.out | 3 +-
.../testIndividualWindowTVF.out} | 264 ++++++------
.../testIndividualWindowTVFProcessingTime.out} | 215 +++++-----
.../plan/stream/sql/WindowDeduplicateTest.xml | 14 +-
.../planner/plan/stream/sql/WindowRankTest.xml | 14 +-
.../plan/stream/sql/WindowTableFunctionTest.xml | 56 +++
.../plan/stream/sql/join/WindowJoinTest.xml | 52 +--
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 3 +-
.../plan/stream/sql/WindowTableFunctionTest.scala | 44 +-
.../harness/WindowTableFunctionHarnessTest.scala | 461 +++++++++++++++++++++
.../stream/sql/WindowTableFunctionITCase.scala | 379 +++++++++++++++++
25 files changed, 1299 insertions(+), 765 deletions(-)
delete mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/SimplifyWindowTableFunctionRules.java
copy flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/{WindowDeduplicateJsonITCase.java => WindowTableFunctionJsonITCase.java} (82%)
copy flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{GroupWindowAggregateJsonPlanTest_jsonplan/testProcTimeSessionWindow.out => WindowTableFunctionJsonPlanTest_jsonplan/testIndividualWindowTVF.out} (73%)
copy flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{WindowAggregateJsonPlanTest_jsonplan/testProcTimeHopWindow.out => WindowTableFunctionJsonPlanTest_jsonplan/testIndividualWindowTVFProcessingTime.out} (79%)
create mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/harness/WindowTableFunctionHarnessTest.scala
create mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/WindowTableFunctionITCase.scala