public interface StreamingListener
Modifier and Type | Method and Description |
---|---|
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
|
void onReceiverStarted(StreamingListenerReceiverStarted receiverStarted)
void onReceiverError(StreamingListenerReceiverError receiverError)
void onReceiverStopped(StreamingListenerReceiverStopped receiverStopped)
void onBatchSubmitted(StreamingListenerBatchSubmitted batchSubmitted)
void onBatchStarted(StreamingListenerBatchStarted batchStarted)
void onBatchCompleted(StreamingListenerBatchCompleted batchCompleted)