org.apache.spark.streaming.api.java

Interface PythonStreamingListener

public interface PythonStreamingListener

Method Summary

Modifier and Type	Method and Description
void	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 error
void	onReceiverStarted(org.apache.spark.streaming.api.java.JavaStreamingListenerReceiverStarted receiverStarted) Called when a receiver has been started
void	onReceiverStopped(org.apache.spark.streaming.api.java.JavaStreamingListenerReceiverStopped receiverStopped) Called when a receiver has been stopped
void	onStreamingStarted(org.apache.spark.streaming.api.java.JavaStreamingListenerStreamingStarted streamingStarted) Called when the streaming has been started

Method Detail

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