Package org.apache.spark.streaming.receiver

Interface Summary

ActorHelper

:: DeveloperApi :: A receiver trait to be mixed in with your Actor to gain access to the API for pushing received data into Spark Streaming for being processed.

Class Summary

ActorSupervisorStrategy	:: DeveloperApi :: A helper with set of defaults for supervisor strategy
CountingIterator<T>	A utility that will wrap the Iterator to get the count
Receiver<T>	:: DeveloperApi :: Abstract class of a receiver that can be run on worker nodes to receive external data.
Statistics	:: DeveloperApi :: Statistics for querying the supervisor about state of workers.