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%)
