Timo Walther created FLINK-19980:
------------------------------------
Summary: Add StreamTableEnvironment.to/fromChangelogStream
Key: FLINK-19980
URL: https://issues.apache.org/jira/browse/FLINK-19980
Project: Flink
Issue Type: Sub-task
Components: Table SQL / API
Reporter: Timo Walther
Assignee: Timo Walther
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.
{code}
StreamTableEnvironment.fromChangelogStream(DataStream<Row>): Table
{code}
Goal: Create a table from a Changelog as easy as possible. Derive schema
entirely.
{code}
StreamTableEnvironment.fromChangelogStream(DataStream<Row>, Schema): Table
{code}
Goal: Create a table from a Changelog with Schema similar to a source.
And similar:
{code}
StreamTableEnvironment.toChangelogStream(Table): DataStream<Row>
StreamTableEnvironment.toChangelogStream(Table, Schema): DataStream<Row>
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
