[FLINK-15331] [umbrella] Create a table from a changelog

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: Table SQL / API
• Assignee: Jark Wu
• Reporter: Timo Walther
• Created: 19/Dec/19 13:20
• Updated: 16/Jun/20 13:05
• Resolved: 16/Jun/20 13:05

Description

This an umbrella issue for the feature of interpreting a changelog as a table. It can be used to collect initial ideas and use cases until a FLIP is proposed.

FLIP-105: https://cwiki.apache.org/confluence/display/FLINK/FLIP-105%3A+Support+to+Interpret+and+Emit+Changelog+in+Flink+SQL

Issue Links

• relates to: FLINK-8545 Implement upsert stream table source
• links to: Example 1
• links to: Example 2
• links to: Example 3
• links to: Example4
• links to: Maybe another use case
• mentioned in: Page Loading...

Sub-Tasks

• Introduce Debezium format to support reading debezium changelogs: Closed
• Introduce Canal format to support reading canal changelogs: Closed
• Add integeration tests for changelog formats: Closed
• Add documentation for the Debezium format: Closed
• Add documentation for the Canal format: Closed