flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gyula Fora <gyf...@apache.org>
Subject Re: Make Streaming Interoperable with Reactive Streams, Java Streams and Rx
Date Thu, 06 Nov 2014 20:50:48 GMT
Hey Suminda,

I am not 100% by what you mean by interoperating, so clarify me if I am off-track here :)

The systems that you have mentioned provide programming models for stream processing systems,
in that sense a lot of features of Flink runtime are similar to these systems but it is presented
in a much higher level API. 

If by interoperating you mean connecting the streams from one systems to another, it is definitely
possible in fact would be probably quite easy. For example a source in the Flink streaming
system would implement a consumer in the other system and could receive messages and process
them. On the other and a Flink sink could be implemented as a Producer for the other systems.

I hope this answers your questions, if not, let me know :)


> On 06 Nov 2014, at 19:09, sirinath <sirinath1978m@gmail.com> wrote:
> Hi,
> Is it possible to add interop with the following projects in Streaming:
> - http://reactive-streams.org/ specification
> - Java Streams
> - If possible http://reactivex.io/
> Suminda
> --
> View this message in context: http://apache-flink-incubator-mailing-list-archive.1008284.n3.nabble.com/Make-Streaming-Interoperable-with-Reactive-Streams-Java-Streams-and-Rx-tp2392.html
> Sent from the Apache Flink (Incubator) Mailing List archive. mailing list archive at

View raw message