[
https://issues.apache.org/jira/browse/FLINK-18840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17179530#comment-17179530
]
Timo Walther commented on FLINK-18840:
--------------------------------------
I will include this topic in the FLIP that I'm currently writing for "Improving
interoperability of DataStream and Table API". I reserved FLIP-136 already.
I agree with Nico. It doesn't have to be possible to convert `StatementSet` to
a `DataStream` object. This doesn't make sense because a `StatementSet` is
always a "leaf" or "leaf subgraph" in the streaming graph. However, it should
be possible to add the subgraph in its optimized form as an additional pipeline
(from source to sink) next to the regular DataStream pipeline.
Add dependency to `flink-streaming-java` for `flink-table-api-java` is not an
option. We should make this functionality available via
`StreamTableEnvironment` only.
> Support StatementSet with DataStream API
> ----------------------------------------
>
> Key: FLINK-18840
> URL: https://issues.apache.org/jira/browse/FLINK-18840
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API
> Reporter: Timo Walther
> Priority: Major
>
> Currently, users of the {{StreamTableEnvironment}} cannot not translate a
> {{StatementSet}} to DataStream API.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
