flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-1344) Add implicit conversion from scala streams to DataStreams
Date Mon, 26 Jan 2015 22:38:34 GMT

    [ https://issues.apache.org/jira/browse/FLINK-1344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14292539#comment-14292539

ASF GitHub Bot commented on FLINK-1344:

Github user StephanEwen commented on the pull request:

    I think this is good to merge.
    In general, relying on static variables to cache things is a bit of a fragile mechanism.
Maybe we can improve that when bringing the Batch and Stream environment together.
    For now, should be good, though.

> 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

View raw message