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 2020/06/05 11:21:23 UTC

[flink] branch release-1.11 updated (ec65e38 -> ce63fd1)

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

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


    from ec65e38  [hotfix][docs] Remove HADOOP_CONF_DIR
     add ce63fd1  [FLINK-15339][table][docs] Correct the terminology of "Time-windowed Join" to "Interval Join" in Table API & SQL

No new revisions were added by this update.

Summary of changes:
 docs/dev/table/sql/queries.md                      | 14 +++++------
 docs/dev/table/sql/queries.zh.md                   | 14 +++++------
 docs/dev/table/streaming/joins.md                  |  8 +++---
 docs/dev/table/streaming/joins.zh.md               |  8 +++---
 docs/dev/table/streaming/match_recognize.md        |  4 +--
 docs/dev/table/streaming/match_recognize.zh.md     |  4 +--
 docs/dev/table/tableApi.md                         | 18 +++++++-------
 docs/dev/table/tableApi.zh.md                      | 18 +++++++-------
 .../plan/metadata/FlinkRelMdColumnUniqueness.scala |  2 +-
 .../metadata/FlinkRelMdModifiedMonotonicity.scala  |  2 +-
 .../plan/metadata/FlinkRelMdUniqueKeys.scala       |  2 +-
 ...ndowJoin.scala => StreamExecIntervalJoin.scala} | 29 +++++++++++-----------
 .../FlinkChangelogModeInferenceProgram.scala       |  8 +++---
 .../planner/plan/rules/FlinkStreamRuleSets.scala   |  2 +-
 ...Rule.scala => StreamExecIntervalJoinRule.scala} | 20 +++++++--------
 .../rules/physical/stream/StreamExecJoinRule.scala |  6 ++---
 .../stream/StreamExecTemporalJoinRule.scala        |  4 +--
 ...WindowJoinUtil.scala => IntervalJoinUtil.scala} |  4 +--
 .../apache/flink/table/api/stream/ExplainTest.xml  |  8 +++---
 .../plan/stream/sql/MiniBatchIntervalInferTest.xml | 12 ++++-----
 .../{WindowJoinTest.xml => IntervalJoinTest.xml}   | 26 +++++++++----------
 .../table/planner/plan/stream/table/JoinTest.xml   | 20 +++++++--------
 .../stream/sql/MiniBatchIntervalInferTest.scala    |  2 +-
 ...WindowJoinTest.scala => IntervalJoinTest.scala} | 14 +++++------
 ...owJoinITCase.scala => IntervalJoinITCase.scala} |  8 +++---
 .../join/{ => interval}/EmitAwareCollector.java    |  2 +-
 .../ProcTimeIntervalJoin.java}                     |  9 ++++---
 .../RowTimeIntervalJoin.java}                      |  9 ++++---
 .../TimeIntervalJoin.java}                         | 20 ++++++++-------
 .../ProcTimeIntervalJoinTest.java}                 | 15 +++++------
 .../RowTimeIntervalJoinTest.java}                  | 22 ++++++++--------
 .../TimeIntervalStreamJoinTestBase.java}           | 12 ++++-----
 32 files changed, 177 insertions(+), 169 deletions(-)
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecWindowJoin.scala => StreamExecIntervalJoin.scala} (92%)
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecWindowJoinRule.scala => StreamExecIntervalJoinRule.scala} (91%)
 rename flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/{WindowJoinUtil.scala => IntervalJoinUtil.scala} (99%)
 rename flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/join/{WindowJoinTest.xml => IntervalJoinTest.xml} (83%)
 rename flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/join/{WindowJoinTest.scala => IntervalJoinTest.scala} (97%)
 rename flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/{WindowJoinITCase.scala => IntervalJoinITCase.scala} (99%)
 rename flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/{ => interval}/EmitAwareCollector.java (96%)
 rename flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/{ProcTimeBoundedStreamJoin.java => interval/ProcTimeIntervalJoin.java} (86%)
 rename flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/{RowTimeBoundedStreamJoin.java => interval/RowTimeIntervalJoin.java} (89%)
 rename flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/{TimeBoundedStreamJoin.java => interval/TimeIntervalJoin.java} (97%)
 rename flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/join/{ProcTimeBoundedStreamJoinTest.java => interval/ProcTimeIntervalJoinTest.java} (94%)
 rename flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/join/{RowTimeBoundedStreamJoinTest.java => interval/RowTimeIntervalJoinTest.java} (95%)
 rename flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/join/{TimeBoundedStreamJoinTestBase.java => interval/TimeIntervalStreamJoinTestBase.java} (88%)