Interface PythonStreamingListener
public interface PythonStreamingListener
-
Method Summary
Modifier and TypeMethodDescriptionvoid
onBatchCompleted
(org.apache.spark.streaming.api.java.JavaStreamingListenerBatchCompleted batchCompleted) Called when processing of a batch of jobs has completed.void
onBatchStarted
(org.apache.spark.streaming.api.java.JavaStreamingListenerBatchStarted batchStarted) Called when processing of a batch of jobs has started.void
onBatchSubmitted
(org.apache.spark.streaming.api.java.JavaStreamingListenerBatchSubmitted batchSubmitted) Called when a batch of jobs has been submitted for processing.void
onOutputOperationCompleted
(org.apache.spark.streaming.api.java.JavaStreamingListenerOutputOperationCompleted outputOperationCompleted) Called when processing of a job of a batch has completed.void
onOutputOperationStarted
(org.apache.spark.streaming.api.java.JavaStreamingListenerOutputOperationStarted outputOperationStarted) Called when processing of a job of a batch has started.void
onReceiverError
(org.apache.spark.streaming.api.java.JavaStreamingListenerReceiverError receiverError) Called when a receiver has reported an errorvoid
onReceiverStarted
(org.apache.spark.streaming.api.java.JavaStreamingListenerReceiverStarted receiverStarted) Called when a receiver has been startedvoid
onReceiverStopped
(org.apache.spark.streaming.api.java.JavaStreamingListenerReceiverStopped receiverStopped) Called when a receiver has been stoppedvoid
onStreamingStarted
(org.apache.spark.streaming.api.java.JavaStreamingListenerStreamingStarted streamingStarted) Called when the streaming has been started
-
Method Details
-
onBatchCompleted
void onBatchCompleted(org.apache.spark.streaming.api.java.JavaStreamingListenerBatchCompleted batchCompleted) Called when processing of a batch of jobs has completed. -
onBatchStarted
void onBatchStarted(org.apache.spark.streaming.api.java.JavaStreamingListenerBatchStarted batchStarted) Called when processing of a batch of jobs has started. -
onBatchSubmitted
void onBatchSubmitted(org.apache.spark.streaming.api.java.JavaStreamingListenerBatchSubmitted batchSubmitted) Called when a batch of jobs has been submitted for processing. -
onOutputOperationCompleted
void onOutputOperationCompleted(org.apache.spark.streaming.api.java.JavaStreamingListenerOutputOperationCompleted outputOperationCompleted) Called when processing of a job of a batch has completed. -
onOutputOperationStarted
void onOutputOperationStarted(org.apache.spark.streaming.api.java.JavaStreamingListenerOutputOperationStarted outputOperationStarted) Called when processing of a job of a batch has started. -
onReceiverError
void onReceiverError(org.apache.spark.streaming.api.java.JavaStreamingListenerReceiverError receiverError) Called when a receiver has reported an error -
onReceiverStarted
void onReceiverStarted(org.apache.spark.streaming.api.java.JavaStreamingListenerReceiverStarted receiverStarted) Called when a receiver has been started -
onReceiverStopped
void onReceiverStopped(org.apache.spark.streaming.api.java.JavaStreamingListenerReceiverStopped receiverStopped) Called when a receiver has been stopped -
onStreamingStarted
void onStreamingStarted(org.apache.spark.streaming.api.java.JavaStreamingListenerStreamingStarted streamingStarted) Called when the streaming has been started
-