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 :)

Gyula

> On 06 Nov 2014, at 19:09, sirinath <[email protected]> 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 Nabble.com.

Reply via email to