| 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 | |
| StreamingListenerShutdown |
An event used in the listener to shutdown the listener daemon thread.
|