[FLINK-8545] Implement upsert stream table source

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Component/s: Table SQL / API
• Assignee: Unassigned
• Reporter: Hequn Cheng
• Created: 01/Feb/18 14:24
• Updated: 07/Dec/20 09:15
• Resolved: 07/Dec/20 09:14

Description

As more and more users are eager for ingesting data with upsert mode in flink sql/table-api, it is valuable to enable table source with upsert mode. I will provide a design doc later and we can have more discussions. Any suggestions are warmly welcomed !

 

Issue Links

• Is contained by: FLINK-19857 FLIP-149: Introduce the upsert-kafka Connector
• Is contained by: FLINK-19976 FLIP-136: Improve interoperability between DataStream and Table API
• is related to: FLINK-15331 [umbrella] Create a table from a changelog

Sub-Tasks

• Implement proctime DataStream to Table upsert conversion.: Closed
• Implement rowtime DataStream to Table upsert conversion.: Closed
• Support deletion flag for DataStream to Table upsert conversion.: Closed
• Adapt documents about DataStream to Table conversion: Closed