[ https://issues.apache.org/jira/browse/FLINK-1344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291787#comment-14291787 ]
ASF GitHub Bot commented on FLINK-1344: --------------------------------------- GitHub user senorcarbone opened a pull request: https://github.com/apache/flink/pull/341 [FLINK-1344] [streaming] Added static StreamExecutionEnvironment initialisation and Implicits for scala sources This PR addresses the ticket [1] for further scala constructs interoperability. I had to add static StreamExecutionEnvironment initialisation to make the implicit conversion possible. [1] https://issues.apache.org/jira/browse/FLINK-1344 You can merge this pull request into a Git repository by running: $ git pull https://github.com/mbalassi/flink scala-seq Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/341.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #341 ---- commit 2ea675895d605e5c0a442171388c7be9361acf79 Author: Paris Carbone <seniorcarb...@gmail.com> Date: 2015-01-23T16:23:46Z [FLINK-1344] [streaming] [scala] Added implicits from scala seq to datastream and static StreamExecutionEnvironment initialization ---- > 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)