|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
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 |
---|
void onReceiverStarted(StreamingListenerReceiverStarted receiverStarted)
void onReceiverError(StreamingListenerReceiverError receiverError)
void onReceiverStopped(StreamingListenerReceiverStopped receiverStopped)
void onBatchSubmitted(StreamingListenerBatchSubmitted batchSubmitted)
void onBatchStarted(StreamingListenerBatchStarted batchStarted)
void onBatchCompleted(StreamingListenerBatchCompleted batchCompleted)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |