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 NetworkReceiver.
|
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 | |
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 |