This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from cb14194 [FLINK-10057] Update FlinkYarnSessionCli.java
new b9c5002 [hotfix][table,test] Deduplicate code in ExpressionTestBase
new 3bc6c13 [hotfix][table,test] Improve error message in
ExpressionTestBase
new 207a7ea [hotfix][table] Rewrite TemporalJoin from CoProcessFunction
to TwoInputStreamOperator
new 2d10acf [FLINK-9715][table] Support temporal join with event time
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../plan/nodes/datastream/DataStreamJoin.scala | 9 +-
.../DataStreamJoinToCoProcessTranslator.scala | 16 +-
...taStreamTemporalJoinToCoProcessTranslator.scala | 103 +++---
...ralJoin.scala => TemporalProcessTimeJoin.scala} | 34 +-
.../table/runtime/join/TemporalRowtimeJoin.scala | 346 +++++++++++++++++++++
.../TemporalTableJoinValidationTest.scala | 15 -
.../expressions/utils/ExpressionTestBase.scala | 70 ++---
.../runtime/harness/TemporalJoinHarnessTest.scala | 248 ++++++++++++++-
.../runtime/stream/sql/TemporalJoinITCase.scala | 35 ++-
9 files changed, 718 insertions(+), 158 deletions(-)
rename
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/{TemporalJoin.scala
=> TemporalProcessTimeJoin.scala} (74%)
create mode 100644
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TemporalRowtimeJoin.scala
