leonardBang opened a new pull request #13299:
URL: https://github.com/apache/flink/pull/13299
## What is the purpose of the change
* This pull request supports Temporal table join in planner.
## Brief change log
- ad6d722 : [FLINK-19072] import Temporal Table join rule
(1) Import temporal table join rule to match all temporal join, lookup join
also belong temporal join
(2) Defferentiate lookup join and general temporal join in according the
join pattern
- 670e795 : [FLINK-19073] Imporve streamExecTemporalJoinRule
(1) Match temporal table join from temporal function in
StreamExecLegacyTemporalJoinRule, Match temporal table join in
StreamTemporalJoinRule
(2) Infer changelog mode trait for temporal table join node
- f0f1e7d2e : [FLINK-19076] Import rule to deal Temporal Join condition
(1) Obtains the unique key from versioned table/view
(2) Prevent join condition(e.g. time attribute column, primary key) push
down by adding temporal join condition in join node
<Note> 0ab4932 and 78e195f will be merged in
https://github.com/apache/flink/pull/13289 , open this PR for review purpose
## Verifying this change
Add plan tests to cover existed lookup join, temporal function and temporal
table join
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): (no)
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: (no)
- The serializers: (no)
- The runtime per-record code paths (performance sensitive): ( no)
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Yarn/Mesos, ZooKeeper: (no)
- The S3 file system connector: (no)
## Documentation
- Does this pull request introduce a new feature? (yes)
- If yes, how is the feature documented? (not applicable / docs / JavaDocs
/ not documented)
JavaDocs, will add docs in FLINK-19082
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
