[
https://issues.apache.org/jira/browse/FLINK-18840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-18840:
---------------------------------
Description:
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.
*/
attachAsDataStream(): Unit
}
{code}
An example could look like:
{code}
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);
tEnv
.createStatementSet()
.addInsert(tEnv.from("FromTable"))
.attachAsDataStream();
tEnv.from("OtherTable").toDataStream(...) // continue with further operations
{code}
was:
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}
> Add StreamStatementSet.attachAsDataStream
> -----------------------------------------
>
> 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
> Assignee: Timo Walther
> Priority: Major
> Labels: pull-request-available, usability
> Fix For: 1.14.0
>
>
> 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.
> */
> attachAsDataStream(): Unit
> }
> {code}
> An example could look like:
> {code}
> StreamExecutionEnvironment env =
> StreamExecutionEnvironment.getExecutionEnvironment();
> StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);
> tEnv
> .createStatementSet()
> .addInsert(tEnv.from("FromTable"))
> .attachAsDataStream();
> tEnv.from("OtherTable").toDataStream(...) // continue with further operations
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
