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:

    https://github.com/apache/flink/pull/341#issuecomment-71553580
  
    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
(v6.3.4#6332)

Mime
View raw message