Package org.apache.spark.streaming.api.java

Interface PythonStreamingListener

public interface PythonStreamingListener

  • Method Summary

    Modifier and Type
    Method
    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 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