org.apache.spark.streaming.scheduler
Interface StreamingListener

All Known Implementing Classes:

StatsReportListener

public interface StreamingListener

:: DeveloperApi :: A listener interface for receiving information about an ongoing streaming computation.

Method Summary

void	onBatchCompleted(StreamingListenerBatchCompleted batchCompleted) Called when processing of a batch of jobs has completed.
void	onBatchStarted(StreamingListenerBatchStarted batchStarted) Called when processing of a batch of jobs has started.
void	onBatchSubmitted(StreamingListenerBatchSubmitted batchSubmitted) Called when a batch of jobs has been submitted for processing.
void	onReceiverError(StreamingListenerReceiverError receiverError) Called when a receiver has reported an error
void	onReceiverStarted(StreamingListenerReceiverStarted receiverStarted) Called when a receiver has been started
void	onReceiverStopped(StreamingListenerReceiverStopped receiverStopped) Called when a receiver has been stopped

Method Detail

onReceiverStarted

void onReceiverStarted(StreamingListenerReceiverStarted receiverStarted)

Called when a receiver has been started

onReceiverError

void onReceiverError(StreamingListenerReceiverError receiverError)

Called when a receiver has reported an error

onReceiverStopped

void onReceiverStopped(StreamingListenerReceiverStopped receiverStopped)

Called when a receiver has been stopped

onBatchSubmitted

void onBatchSubmitted(StreamingListenerBatchSubmitted batchSubmitted)

Called when a batch of jobs has been submitted for processing.

onBatchStarted

void onBatchStarted(StreamingListenerBatchStarted batchStarted)

Called when processing of a batch of jobs has started.

onBatchCompleted

void onBatchCompleted(StreamingListenerBatchCompleted batchCompleted)

Called when processing of a batch of jobs has completed.