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 f48ffe5 [FLINK-19213][docs-zh] Translate "Confluent Avro Format" page
into Chinese
add faf500d [FLINK-19077][table-blink] Support processing time temporal
table join in runtime
No new revisions were added by this update.
Summary of changes:
docs/dev/table/hive/hive_streaming.md | 2 +-
docs/dev/table/hive/hive_streaming.zh.md | 2 +-
.../calcite/RelTimeIndicatorConverter.scala | 2 +-
.../stream/StreamExecLegacyTemporalJoin.scala | 418 -------------------
.../physical/stream/StreamExecTemporalJoin.scala | 333 ++++++++++++++-
.../FlinkChangelogModeInferenceProgram.scala | 24 --
.../planner/plan/rules/FlinkStreamRuleSets.scala | 1 -
...relateToJoinFromTemporalTableFunctionRule.scala | 14 +-
...gicalCorrelateToJoinFromTemporalTableRule.scala | 15 +-
.../TemporalJoinRewriteWithUniqueKeyRule.scala | 77 ++--
.../rules/physical/stream/StreamExecJoinRule.scala | 5 +-
.../stream/StreamExecLegacyTemporalJoinRule.scala | 103 -----
.../stream/StreamExecTemporalJoinRule.scala | 47 ++-
.../plan/utils/LegacyTemporalJoinUtil.scala | 106 -----
.../planner/plan/utils/TemporalJoinUtil.scala | 297 ++++++++++++--
...calCorrelateToJoinFromTemporalTableRuleTest.xml | 6 +-
.../TemporalJoinRewriteWithUniqueKeyRuleTest.xml | 4 +-
.../physical/stream/ChangelogModeInferenceTest.xml | 4 +-
.../plan/stream/sql/MiniBatchIntervalInferTest.xml | 2 +-
...alJoinTest.xml => TemporalFunctionJoinTest.xml} | 8 +-
.../plan/stream/sql/join/TemporalJoinTest.xml | 38 +-
.../stream/table/TemporalTableFunctionJoinTest.xml | 134 ++++++
...inTest.scala => TemporalFunctionJoinTest.scala} | 2 +-
...t.scala => TemporalTableFunctionJoinTest.scala} | 2 +-
.../TemporalJoinRewriteWithUniqueKeyRuleTest.scala | 12 +-
...inTest.scala => TemporalFunctionJoinTest.scala} | 6 +-
.../plan/stream/sql/join/TemporalJoinTest.scala | 33 +-
...t.scala => TemporalTableFunctionJoinTest.scala} | 2 +-
.../runtime/stream/sql/TemporalJoinITCase.scala | 455 +++++++++++----------
...scala => TemporalTableFunctionJoinITCase.scala} | 4 +-
...r.java => TemporalProcessTimeJoinOperator.java} | 50 ++-
...va => TemporalProcessTimeJoinOperatorTest.java} | 139 +++++--
...t.java => TemporalRowTimeJoinOperatorTest.java} | 66 +--
....java => TemporalTimeJoinOperatorTestBase.java} | 11 +-
34 files changed, 1336 insertions(+), 1088 deletions(-)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecLegacyTemporalJoin.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/StreamExecLegacyTemporalJoinRule.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/LegacyTemporalJoinUtil.scala
rename
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/join/{LegacyTemporalJoinTest.xml
=> TemporalFunctionJoinTest.xml} (87%)
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/table/TemporalTableFunctionJoinTest.xml
rename
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/join/{LegacyTemporalJoinTest.scala
=> TemporalFunctionJoinTest.scala} (98%)
rename
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/batch/table/{TemporalTableJoinTest.scala
=> TemporalTableFunctionJoinTest.scala} (97%)
rename
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/join/{LegacyTemporalJoinTest.scala
=> TemporalFunctionJoinTest.scala} (96%)
rename
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/table/{TemporalTableJoinTest.scala
=> TemporalTableFunctionJoinTest.scala} (99%)
copy
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/{TemporalJoinITCase.scala
=> TemporalTableFunctionJoinITCase.scala} (98%)
rename
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/temporal/{LegacyTemporalProcessTimeJoinOperator.java
=> TemporalProcessTimeJoinOperator.java} (73%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/join/temporal/{LegacyTemporalProcessTimeJoinOperatorTest.java
=> TemporalProcessTimeJoinOperatorTest.java} (51%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/join/temporal/{LegacyTemporalRowTimeJoinOperatorTest.java
=> TemporalRowTimeJoinOperatorTest.java} (87%)
rename
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/join/temporal/{LegacyTemporalTimeJoinOperatorTestBase.java
=> TemporalTimeJoinOperatorTestBase.java} (85%)
