[
https://issues.apache.org/jira/browse/FLINK-1344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paris Carbone updated FLINK-1344:
---------------------------------
Description:
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.)
was:
Source definitions in the scala-api pass a collector to the UDF, thus enforcing
an imperative style for defining custom streams. To encourage a purely
functional coding style in the streaming scala-api while also adding some
interoperability with scala constructs (ie. Seq and Streams) it would be nice
to add an implicit conversion from Seq[T] to DataStream[T].
(An upcoming idea would be for sinks to also support wrapping up flink streams
to scala streams for full interoperability with scala streaming code.)
> 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)
