[FLINK-8577] Implement proctime DataStream to Table upsert conversion.

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Hequn Cheng
• Reporter: Hequn Cheng
• Created: 07/Feb/18 10:44
• Updated: 07/Dec/20 09:16
• Resolved: 07/Dec/20 09:15

Description

Api will looks like:

DataStream[(String, Long, Int)] input = ???
// upsert with keyTable 
table = tEnv.upsertFromStream(input, 'a, 'b, 'c.key)
// upsert without key -> single row tableTable 
table = tEnv.upsertFromStream(input, 'a, 'b, 'c)

A simple design doc about this subtask.

Issue Links

• links to: GitHub Pull Request #6787