You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Paris Carbone (JIRA)" <ji...@apache.org> on 2015/01/28 17:17:35 UTC

[jira] [Closed] (FLINK-1344) Add implicit conversion from scala streams to DataStreams

     [ https://issues.apache.org/jira/browse/FLINK-1344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Paris Carbone closed FLINK-1344.
--------------------------------

> Add implicit conversion from scala streams to DataStreams
> ---------------------------------------------------------
>
>                 Key: FLINK-1344
>                 URL: https://issues.apache.org/jira/browse/FLINK-1344
>             Project: Flink
>          Issue Type: New Feature
>          Components: Streaming
>            Reporter: Paris Carbone
>            Assignee: Paris Carbone
>            Priority: Trivial
>
> Source definitions in the scala-api work either with a collector in a UDF, or by passing a Seq that could also be a lazily generated scala Stream. To encourage a purely functional coding style in the streaming scala-api while also adding some interoperability with scala constructs (ie. Streams, Lists) it would be nice to add an implicit conversion from Seq[T] to DataStream[T]. 
> [EDIT] The StreamExecutionEnvironment should be statically initialised to allow for an implicit source definition
> (An upcoming idea would be for sinks to also support wrapping up flink streams to scala streams for full interoperability with scala streaming code.)



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)