[
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 <[email protected]>
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)
