You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2021/03/17 11:11:09 UTC
[flink] branch master updated (83d6698 -> 20cb469)

This is an automated email from the ASF dual-hosted git repository.

jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 83d6698  [FLINK-21774][sql-client] Display all the SHOW command result in tableau format
     add 20cb469  [FLINK-19609][table-planner-blink] Support streaming window join in planner (#15195)

No new revisions were added by this update.

Summary of changes:
 .../planner/plan/logical/CumulativeWindowSpec.java |    7 +
 .../planner/plan/logical/HoppingWindowSpec.java    |    7 +
 .../planner/plan/logical/TumblingWindowSpec.java   |    5 +
 .../plan/metadata/FlinkRelMdWindowProperties.scala |   70 +-
 ...alJoin.scala => StreamPhysicalWindowJoin.scala} |   82 +-
 .../FlinkChangelogModeInferenceProgram.scala       |   11 +-
 .../planner/plan/rules/FlinkStreamRuleSets.scala   |    1 +
 .../physical/stream/StreamPhysicalJoinRule.scala   |    6 +
 .../stream/StreamPhysicalTemporalJoinRule.scala    |    7 +-
 .../stream/StreamPhysicalWindowJoinRule.scala      |  116 +++
 .../table/planner/plan/utils/WindowJoinUtil.scala  |  227 +++++
 .../plan/stream/sql/join/WindowJoinTest.xml        | 1041 ++++++++++++++++++++
 .../plan/stream/sql/join/WindowJoinTest.scala      |  979 ++++++++++++++++++
 13 files changed, 2514 insertions(+), 45 deletions(-)
 copy flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamPhysicalIntervalJoin.scala => StreamPhysicalWindowJoin.scala} (50%)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/StreamPhysicalWindowJoinRule.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowJoinUtil.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/join/WindowJoinTest.xml
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/join/WindowJoinTest.scala