ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Lalit Kumar Jha <lalitj....@gmail.com>
Subject Re: Brainstorming about Reactive Streams
Date Sun, 20 Sep 2015 18:59:05 GMT
Yes, lets first explore how reactive-streams can be useful for Ignite.

Adding one more candidate to list http://projectreactor.io/docs/, as this
project:
Is for fast-data applications
Team are core contributors to the Reactive Streams Specification
<https://github.com/reactive-streams/reactive-streams>



On Sun, Sep 20, 2015 at 10:33 PM, Sergi Vladykin <sergi.vladykin@gmail.com>
wrote:

> Guys,
>
> I think you are digging too deep in implementation possibilities right
> away, may be lets start from simpler things?
> I don't know much about reactive streams and probably not everyone in the
> community that educated as well :)
>
> It would be nice to start with a quick overview of what are they and why in
> makes sense to
> to add such a functionality to Ignite? What real use cases do you see? How
> can Ignite
> be useful for reactive streams users and vice versa?
>
> Lets get clear answers to these questions first to avoid writing useless
> code.
>
> Sergi
>
> 2015-09-20 18:55 GMT+03:00 Raul Kripalani <raul@evosent.com>:
>
> > Yeah, the idea would be to wrap RxJava 1.0 with the adapter and only use
> > the Reactive Streams API where possible from within Ignite.
> >
> > Nevertheless, the ReactiveX API would also be accessible in case we want
> to
> > do stuff with Hystrix too.
> >
> > Raúl.
> > On 20 Sep 2015 16:39, "Vishal Garg" <gargvish@gmail.com> wrote:
> >
> > > https://github.com/ReactiveX/RxJava/wiki/R
> > > eactive-Streams
> > > +1 on your approach ( if we are wrapping 1.0 with adapters??)
> > > Raul it looks like there is a path to convergence in RxJava 2.0, but
> > above
> > > link mentions that you could use the standard + integration modules
> with
> > > wrappers on core 1.0 Apis. Where the modules could be Akka or RxJava
> > > Vishal
> > >
> > >
> > >
> > > Sent from my iPhone
> > >
> > > > On Sep 20, 2015, at 7:03 AM, Gianfranco Murador <
> > > murador.gianfranco@gmail.com> wrote:
> > > >
> > > > Hy Raul, it could be a valid extension of the Service Grid of Ignite
> (
> > > if I
> > > > understand the point), imho.
> > > >
> > > > 2015-09-20 14:37 GMT+02:00 Raul Kripalani <raulk@apache.org>:
> > > >
> > > >> Hey Igniters,
> > > >>
> > > >> Lalit Kumar Jha expressed interest [1] in contributing to ticket
> > > IGNITE-815
> > > >> [2] which aims to bring in Reactive Streams to Ignite.
> > > >>
> > > >> I wanted to start a brainstorm about which functionalities we'd like
> > to
> > > >> cover.
> > > >>
> > > >> Off the top of my head, I can think of merging, filtering, sorting,
> > > >> batching, grouping, etc. on Data Streams, Ignite Messages and
> Events.
> > > Also,
> > > >> integration with Continuous Queries would be useful.
> > > >>
> > > >> Furthermore, I wanted to ask the community if at this point we feel
> > > >> comfortable with Reactive Streams per-se or we prefer to go with
> > RxJava
> > > for
> > > >> now. Reactive Streams is a proposed standard whose main Java
> > > implementation
> > > >> and is slowly gaining traction (e.g. vert.x [3] and MongoDB
> > integrations
> > > >> [4]), whereas RxJava is an already mature and production-tested
> > > >> implementation of the initial ReactiveX design by Microsoft [5] with
> > > 7000+
> > > >> stars on GitHub.
> > > >>
> > > >> RxJava is the foundation of Hystrix [6], a powerful library for
> > latency
> > > and
> > > >> fault tolerance management. RxJava does not implement Reactive
> Streams
> > > as
> > > >> of 1.x (as they predated it), but they've vowed support for 2.x [7].
> > > >> Moreover, there's already an adapter which passes the TCK [8].
> > > >>
> > > >> My take is as follows. I'd like to follow the Reactive Streams
> > standard,
> > > >> but I wouldn't like to lose support for Hystrix (hopefully it'll
> > > eventually
> > > >> be migrated to Reactive Streams too). So an option is to go with the
> > > RxJava
> > > >> + adapter design for now to get the best of both worlds. Once RxJava
> > > 2.0 is
> > > >> out, we can drop the adapter out of the picture.
> > > >>
> > > >> Thoughts?
> > > >>
> > > >> [1]
> > > >>
> > > >>
> > >
> >
> http://apache-ignite-developers.2346864.n4.nabble.com/Hello-Apache-Ignite-Dev-tp3137p3315.html
> > > >> [2] https://issues.apache.org/jira/browse/IGNITE-815
> > > >> [3] http://vertx.io/docs/vertx-reactive-streams/java/
> > > >> [4] https://mongodb.github.io/mongo-java-driver-reactivestreams/
> > > >> [5] https://msdn.microsoft.com/en-us/data/gg577609.aspx
> > > >> [6] https://github.com/Netflix/Hystrix
> > > >> [7] https://github.com/ReactiveX/RxJava/wiki/Reactive-Streams
> > > >> [8] https://github.com/ReactiveX/RxJavaReactiveStreams
> > > >>
> > > >> Regards,
> > > >>
> > > >> *Raúl Kripalani*
> > > >> Apache Camel PMC Member & Committer | Enterprise Architect, Open
> > Source
> > > >> Integration specialist
> > > >> http://about.me/raulkripalani |
> > > http://www.linkedin.com/in/raulkripalani
> > > >> http://blog.raulkr.net | twitter: @raulvk
> > > >>
> > >
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message