Package org.apache.spark.streaming.receiver

Interface Summary

Interface	Description
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.
ActorReceiverData	Case class to receive data sent by child actors
BlockGeneratorListener	Listener object for BlockGenerator events
ReceivedBlock	Trait representing a received block
ReceivedBlockHandler	Trait that represents a class that handles the storage of blocks received by receiver
ReceivedBlockStoreResult	Trait that represents the metadata related to storage of blocks
ReceiverMessage	Messages sent to the Receiver.

Class Summary

Class	Description
ActorReceiver<T>	Provides Actors as receivers for receiving stream.
ActorSupervisorStrategy	:: DeveloperApi :: A helper with set of defaults for supervisor strategy
ArrayBufferBlock	class representing a block received as an ArrayBuffer
BlockGenerator	Generates batches of objects received by a Receiver and puts them into appropriately named blocks at regular intervals.
BlockManagerBasedBlockHandler	Implementation of a ReceivedBlockHandler which stores the received blocks into a block manager with the specified storage level.
BlockManagerBasedStoreResult	Implementation of ReceivedBlockStoreResult that stores the metadata related to storage of blocks using BlockManagerBasedBlockHandler
ByteBufferBlock	class representing a block received as an ByteBuffer
ByteBufferData
CleanupOldBlocks
IteratorBlock	class representing a block received as an Iterator
IteratorData<T>
RateLimiter	Provides waitToPush() method to limit the rate at which receivers consume data.
Receiver<T>	:: DeveloperApi :: Abstract class of a receiver that can be run on worker nodes to receive external data.
ReceiverSupervisor	Abstract class that is responsible for supervising a Receiver in the worker.
ReceiverSupervisorImpl	Concrete implementation of ReceiverSupervisor which provides all the necessary functionality for handling the data received by the receiver.
SingleItemData<T>
Statistics	:: DeveloperApi :: Statistics for querying the supervisor about state of workers.
StopReceiver
WriteAheadLogBasedBlockHandler	Implementation of a ReceivedBlockHandler which stores the received blocks in both, a write ahead log and a block manager.
WriteAheadLogBasedStoreResult	Implementation of ReceivedBlockStoreResult that stores the metadata related to storage of blocks using WriteAheadLogBasedBlockHandler