[
https://issues.apache.org/jira/browse/FLINK-18840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-18840:
----------------------------------
Labels: usability (was: )
> Add StreamStatementSet.attachToStream
> -------------------------------------
>
> Key: FLINK-18840
> URL: https://issues.apache.org/jira/browse/FLINK-18840
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / API
> Reporter: Timo Walther
> Priority: Major
> Labels: usability
>
> StatementSet solves use cases for pure SQL & Table API pipelines. However,
> currently there is no way of creating StatementSet for a DataStream API job.
> We propose the following API:
> {code}
> StreamTableEnvironment.createStatementSet(): StreamStatementSet // return a
> stream-specific set
> StreamStatementSet extends StatementSet {
> /**
> * Attaches the optimized statement set to the DataStream pipeline.
> */
> attachToStream(): Unit
> }
> {code}
> An example could look like:
> {code}
> StreamExecutionEnvironment env =
> StreamExecutionEnvironment.getExecutionEnvironment();
> StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);
> tEnv
> .createStatementSet()
> .addInsert(tEnv.from("FromTable"))
> .attachToStream();
> tEnv.from("OtherTable").toDataStream(...) // continue with further operations
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
