[FLINK-16824] FLIP-132 Temporal Table DDL and Temporal Table Join

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Resolved
• Fix Version/s: 1.12.0
• Component/s: Table SQL / API
• Assignee: Leonard Xu
• Reporter: Konstantin Knauf
• Created: 27/Mar/20 08:50
• Updated: 22/Apr/21 04:08
• Resolved: 22/Apr/21 04:08

Description

Currently, a Temporal Table Function can only be created via the Table API or indirectly via the configuration file of the SQL Client.

It would be great, if this was also possible in pure SQL via a DDL statement.

Issue Links

• mentioned in: Page Loading...
• mentioned in: Page Loading...

Sub-Tasks

• Support temporal join on temporal table with computed columns: Closed
• Improve FlinkCalcMergeRule to merge calc nodes better: Closed
• Improve streamExecTemporalJoinRule: Closed
• Import Temporal Table join rule: Closed
• Import rule to deal Temporal Join condition: Closed
• Import process time temporal join operator: Closed
• Import rowtime join temporal operator: Closed
• Support row time deduplicate operator: Closed
• Materialize TimeIndicatorRelDataType in the right input of temporal join: Resolved
• Deprecate TemporalTableFunction and Table#createTemporalTableFunction(): Closed
• Add docs for temporal table and temporal table join: Resolved
• Replace 'collection' connector by 'values' connector for temporal join plan tests: Closed
• Add end-to-end IT case for Debezium + Kafka + temporal join: Closed