Interface | Description |
---|---|
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.
|