[FLINK-8545] Implement upsert stream table source

• Type: New Feature
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Table SQL / API
• Assignee: Hequn Cheng
• Reporter: Hequn Cheng
• Created: 01/Feb/18 14:24
• Updated: 11/Mar/20 21:56

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 related to: FLINK-15331 Create a table from a changelog

Sub-Tasks

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