Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Receiver class should be deployed on the cluster prior to data streamer usage - see IEP-103: Code Deployment.

Reactive Java API

Java 9 Reactive Streams is a standard API for asynchronous stream processing (initially inspired by Akka Streams). Our API will accept Flow.Publisherfrom the user and pull the data from there as needed, at the speed of server-side ingestion and processing.

...