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:19:14 UTC
[flink] branch master updated (b48d330 -> b39ef6c)
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 b48d330 [hotfix][docs] Remove HADOOP_CONF_DIR
add b39ef6c [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%)