| Interface | Description |
|---|---|
| JobGeneratorEvent |
Event classes for JobGenerator
|
| JobSchedulerEvent | |
| ReceivedBlockTrackerLogEvent |
Trait representing any event in the ReceivedBlockTracker that updates its state.
|
| ReceiverTrackerLocalMessage |
Messages used by the driver and ReceiverTrackerEndpoint to communicate locally.
|
| 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 |
|---|---|
| AllReceiverIds |
A message used by ReceiverTracker to ask all receiver's ids still stored in
ReceiverTrackerEndpoint.
|
| BatchInfo |
:: DeveloperApi ::
Class having information on completed batches.
|
| GetAllReceiverInfo | |
| OutputOperationInfo |
:: DeveloperApi ::
Class having information on output operations.
|
| ReceiverInfo |
:: DeveloperApi ::
Class having information about a receiver
|
| ReceiverState |
Enumeration to identify current state of a Receiver
|
| StatsReportListener |
:: DeveloperApi ::
A simple StreamingListener that logs summary statistics across Spark Streaming batches
param: numBatchInfos Number of last batches to consider for generating statistics (default: 10)
|
| StopAllReceivers |
This message will trigger ReceiverTrackerEndpoint to send stop signals to all registered
receivers.
|
| StreamingListenerBatchCompleted | |
| StreamingListenerBatchStarted | |
| StreamingListenerBatchSubmitted | |
| StreamingListenerOutputOperationCompleted | |
| StreamingListenerOutputOperationStarted | |
| StreamingListenerReceiverError | |
| StreamingListenerReceiverStarted | |
| StreamingListenerReceiverStopped | |
| StreamingListenerStreamingStarted | |
| StreamInputInfo |
:: DeveloperApi ::
Track the information of input stream at specified batch time.
|