Paris Carbone created FLINK-1344:
------------------------------------
Summary: Add support for lazy collections and scala streams for
functional source definitions
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 pass a collector to the UDF, thus enforcing
an imperative style for defining custom streams. In order maintain a purely
functional coding style in the streaming scala-api while also adding some
interoperability with scala constructs it would be nice to add a source
definition that gets a generating lazily collection or a scala/akka stream and
just delegates internally the calls to the collector while iterating them. Mind
that source parallelism should be 1.
As an additional idea, sinks could 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)
