Interface | Description |
---|---|
JobGeneratorEvent |
Event classes for JobGenerator
|
JobSchedulerEvent | |
ReceivedBlockTrackerLogEvent |
Trait representing any event in the ReceivedBlockTracker that updates its state.
|
ReceiverTrackerMessage |
Messages used by the NetworkReceiver and the ReceiverTracker to communicate
with each other.
|
StreamingListener |
:: DeveloperApi ::
A listener interface for receiving information about an ongoing streaming
computation.
|
StreamingListenerEvent |
:: DeveloperApi ::
Base trait for events related to StreamingListener
|
Class | Description |
---|---|
AddBlock | |
AllocatedBlocks |
Class representing the blocks of all the streams allocated to a batch
|
BatchAllocationEvent | |
BatchCleanupEvent | |
BatchInfo |
:: DeveloperApi ::
Class having information on completed batches.
|
BlockAdditionEvent | |
ClearCheckpointData | |
ClearMetadata | |
DeregisterReceiver | |
DoCheckpoint | |
ErrorReported | |
GenerateJobs | |
Job |
Class representing a Spark computation.
|
JobCompleted | |
JobGenerator |
This class generates jobs from DStreams as well as drives checkpointing and cleaning
up DStream metadata.
|
JobScheduler |
This class schedules jobs to be run on Spark.
|
JobSet |
Class representing a set of Jobs
belong to the same batch.
|
JobStarted | |
ReceivedBlockInfo |
Information about blocks received by the receiver
|
ReceivedBlockTracker |
Class that keep track of all the received blocks, and allocate them to batches
when required.
|
ReceiverInfo |
:: DeveloperApi ::
Class having information about a receiver
|
ReceiverTracker |
This class manages the execution of the receivers of ReceiverInputDStreams.
|
RegisterReceiver | |
ReportError | |
StatsReportListener |
:: DeveloperApi ::
A simple StreamingListener that logs summary statistics across Spark Streaming batches
|
StreamingListenerBatchCompleted | |
StreamingListenerBatchStarted | |
StreamingListenerBatchSubmitted | |
StreamingListenerBus |
Asynchronously passes StreamingListenerEvents to registered StreamingListeners.
|
StreamingListenerReceiverError | |
StreamingListenerReceiverStarted | |
StreamingListenerReceiverStopped |