[jira] [Created] (FLINK-19980) Add StreamTableEnvironment.to/fromChangelogStream

["Timo Walther (Jira)" <ji...@apache.org>]

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)