[FLINK-19980] Add StreamTableEnvironment.to/fromChangelogStream

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.13.0
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Timo Walther
• Reporter: Timo Walther
• Created: 04/Nov/20 15:41
• Updated: 28/May/21 09:11
• Resolved: 22/Apr/21 09:17

Description

The more powerful API exposes the same features as a DynamicTableSource/Sink in FLIP-95. It enables ingesting a changelog stream with primary key, computed columns, and watermarks.

StreamTableEnvironment.fromChangelogStream(DataStream<Row>): Table

Goal: Create a table from a Changelog as easy as possible. Derive schema entirely.

StreamTableEnvironment.fromChangelogStream(DataStream<Row>, Schema): Table

Goal: Create a table from a Changelog with Schema similar to a source.

And similar:

StreamTableEnvironment.toChangelogStream(Table): DataStream<Row>
StreamTableEnvironment.toChangelogStream(Table, Schema): DataStream<Row>

Issue Links

• links to: GitHub Pull Request #15699