ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sergi Vladykin <sergi.vlady...@gmail.com>
Subject Re: Brainstorming about Reactive Streams
Date Sun, 20 Sep 2015 17:03:12 GMT
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