Nicolas A Perez

Building on top of Reactive Streams

Reactive Streams

The Reactive Streams specifications allow us to create application components that communicate in a async fashion while maintaining safety using back pressure mechanisms.

First of all, congratulations in your success.

I do have a similar story organizing Miami Scala User Group (https://www.meetup.com/Miami-Scala-Enthusiasts/). Our first meeting May 25, 2016 and we have been meeting every month without exceptions. Our group now has 191 members and growing. Last week we did the first one day…

they are not the same and The advantage is the loging part. Your suggestion is to have an RDD[(List[OperationResult], Person] but this is just a distributed collection. With the Writer, we are saying that for each state of the RDD transformation we have a corresponding message that describes the transformation. Now, we can group transformations like…