Interface | Description |
---|---|
StreamingListener | Developer API
A listener interface for receiving information about an ongoing streaming
computation.
|
StreamingListenerEvent | Developer API
Base trait for events related to StreamingListener
|
Class | Description |
---|---|
BatchInfo | Developer API
Class having information on completed batches.
|
OutputOperationInfo | Developer API
Class having information on output operations.
|
ReceiverInfo | Developer API
Class having information about a receiver
|
StatsReportListener | Developer API
A simple StreamingListener that logs summary statistics across Spark Streaming batches
param: numBatchInfos Number of last batches to consider for generating statistics (default: 10)
|
StreamingListenerBatchCompleted | |
StreamingListenerBatchStarted | |
StreamingListenerBatchSubmitted | |
StreamingListenerOutputOperationCompleted | |
StreamingListenerOutputOperationStarted | |
StreamingListenerReceiverError | |
StreamingListenerReceiverStarted | |
StreamingListenerReceiverStopped | |
StreamInputInfo | Developer API
Track the information of input stream at specified batch time.
|