Package org.apache.spark.scheduler

Class SparkListener

Object
org.apache.spark.scheduler.SparkListener
All Implemented Interfaces:
org.apache.spark.scheduler.SparkListenerInterface
Direct Known Subclasses:
StatsReportListener
public abstract class SparkListener extends Object implements org.apache.spark.scheduler.SparkListenerInterface
:: DeveloperApi :: A default implementation for SparkListenerInterface that has no-op implementations for all callbacks.

Note that this is an internal interface which might change in different Spark releases.

  • Constructor Details

    • SparkListener

      public SparkListener()

  • Method Details

    • onApplicationEnd

      public void onApplicationEnd(SparkListenerApplicationEnd applicationEnd)
      Specified by:
      onApplicationEnd in interface org.apache.spark.scheduler.SparkListenerInterface

    • onApplicationStart

      public void onApplicationStart(SparkListenerApplicationStart applicationStart)
      Specified by:
      onApplicationStart in interface org.apache.spark.scheduler.SparkListenerInterface

    • onBlockManagerAdded

      public void onBlockManagerAdded(SparkListenerBlockManagerAdded blockManagerAdded)
      Specified by:
      onBlockManagerAdded in interface org.apache.spark.scheduler.SparkListenerInterface

    • onBlockManagerRemoved

      public void onBlockManagerRemoved(SparkListenerBlockManagerRemoved blockManagerRemoved)
      Specified by:
      onBlockManagerRemoved in interface org.apache.spark.scheduler.SparkListenerInterface

    • onBlockUpdated

      public void onBlockUpdated(SparkListenerBlockUpdated blockUpdated)
      Specified by:
      onBlockUpdated in interface org.apache.spark.scheduler.SparkListenerInterface

    • onEnvironmentUpdate

      public void onEnvironmentUpdate(SparkListenerEnvironmentUpdate environmentUpdate)
      Specified by:
      onEnvironmentUpdate in interface org.apache.spark.scheduler.SparkListenerInterface

    • onExecutorAdded

      public void onExecutorAdded(SparkListenerExecutorAdded executorAdded)
      Specified by:
      onExecutorAdded in interface org.apache.spark.scheduler.SparkListenerInterface

    • onExecutorBlacklisted

      public void onExecutorBlacklisted(SparkListenerExecutorBlacklisted executorBlacklisted)
      Specified by:
      onExecutorBlacklisted in interface org.apache.spark.scheduler.SparkListenerInterface

    • onExecutorBlacklistedForStage

      public void onExecutorBlacklistedForStage(SparkListenerExecutorBlacklistedForStage executorBlacklistedForStage)
      Specified by:
      onExecutorBlacklistedForStage in interface org.apache.spark.scheduler.SparkListenerInterface

    • onExecutorExcluded

      public void onExecutorExcluded(SparkListenerExecutorExcluded executorExcluded)
      Specified by:
      onExecutorExcluded in interface org.apache.spark.scheduler.SparkListenerInterface

    • onExecutorExcludedForStage

      public void onExecutorExcludedForStage(SparkListenerExecutorExcludedForStage executorExcludedForStage)
      Specified by:
      onExecutorExcludedForStage in interface org.apache.spark.scheduler.SparkListenerInterface

    • onExecutorMetricsUpdate

      public void onExecutorMetricsUpdate(SparkListenerExecutorMetricsUpdate executorMetricsUpdate)
      Specified by:
      onExecutorMetricsUpdate in interface org.apache.spark.scheduler.SparkListenerInterface

    • onExecutorRemoved

      public void onExecutorRemoved(SparkListenerExecutorRemoved executorRemoved)
      Specified by:
      onExecutorRemoved in interface org.apache.spark.scheduler.SparkListenerInterface

    • onExecutorUnblacklisted

      public void onExecutorUnblacklisted(SparkListenerExecutorUnblacklisted executorUnblacklisted)
      Specified by:
      onExecutorUnblacklisted in interface org.apache.spark.scheduler.SparkListenerInterface

    • onExecutorUnexcluded

      public void onExecutorUnexcluded(SparkListenerExecutorUnexcluded executorUnexcluded)
      Specified by:
      onExecutorUnexcluded in interface org.apache.spark.scheduler.SparkListenerInterface

    • onJobEnd

      public void onJobEnd(SparkListenerJobEnd jobEnd)
      Specified by:
      onJobEnd in interface org.apache.spark.scheduler.SparkListenerInterface

    • onJobStart

      public void onJobStart(SparkListenerJobStart jobStart)
      Specified by:
      onJobStart in interface org.apache.spark.scheduler.SparkListenerInterface

    • onNodeBlacklisted

      public void onNodeBlacklisted(SparkListenerNodeBlacklisted nodeBlacklisted)
      Specified by:
      onNodeBlacklisted in interface org.apache.spark.scheduler.SparkListenerInterface

    • onNodeBlacklistedForStage

      public void onNodeBlacklistedForStage(SparkListenerNodeBlacklistedForStage nodeBlacklistedForStage)
      Specified by:
      onNodeBlacklistedForStage in interface org.apache.spark.scheduler.SparkListenerInterface

    • onNodeExcluded

      public void onNodeExcluded(SparkListenerNodeExcluded nodeExcluded)
      Specified by:
      onNodeExcluded in interface org.apache.spark.scheduler.SparkListenerInterface

    • onNodeExcludedForStage

      public void onNodeExcludedForStage(SparkListenerNodeExcludedForStage nodeExcludedForStage)
      Specified by:
      onNodeExcludedForStage in interface org.apache.spark.scheduler.SparkListenerInterface

    • onNodeUnblacklisted

      public void onNodeUnblacklisted(SparkListenerNodeUnblacklisted nodeUnblacklisted)
      Specified by:
      onNodeUnblacklisted in interface org.apache.spark.scheduler.SparkListenerInterface

    • onNodeUnexcluded

      public void onNodeUnexcluded(SparkListenerNodeUnexcluded nodeUnexcluded)
      Specified by:
      onNodeUnexcluded in interface org.apache.spark.scheduler.SparkListenerInterface

    • onOtherEvent

      public void onOtherEvent(SparkListenerEvent event)
      Specified by:
      onOtherEvent in interface org.apache.spark.scheduler.SparkListenerInterface

    • onResourceProfileAdded

      public void onResourceProfileAdded(SparkListenerResourceProfileAdded event)
      Specified by:
      onResourceProfileAdded in interface org.apache.spark.scheduler.SparkListenerInterface

    • onSpeculativeTaskSubmitted

      public void onSpeculativeTaskSubmitted(SparkListenerSpeculativeTaskSubmitted speculativeTask)
      Specified by:
      onSpeculativeTaskSubmitted in interface org.apache.spark.scheduler.SparkListenerInterface

    • onStageCompleted

      public void onStageCompleted(SparkListenerStageCompleted stageCompleted)
      Specified by:
      onStageCompleted in interface org.apache.spark.scheduler.SparkListenerInterface

    • onStageExecutorMetrics

      public void onStageExecutorMetrics(SparkListenerStageExecutorMetrics executorMetrics)
      Specified by:
      onStageExecutorMetrics in interface org.apache.spark.scheduler.SparkListenerInterface

    • onStageSubmitted

      public void onStageSubmitted(SparkListenerStageSubmitted stageSubmitted)
      Specified by:
      onStageSubmitted in interface org.apache.spark.scheduler.SparkListenerInterface

    • onTaskEnd

      public void onTaskEnd(SparkListenerTaskEnd taskEnd)
      Specified by:
      onTaskEnd in interface org.apache.spark.scheduler.SparkListenerInterface

    • onTaskGettingResult

      public void onTaskGettingResult(SparkListenerTaskGettingResult taskGettingResult)
      Specified by:
      onTaskGettingResult in interface org.apache.spark.scheduler.SparkListenerInterface

    • onTaskStart

      public void onTaskStart(SparkListenerTaskStart taskStart)
      Specified by:
      onTaskStart in interface org.apache.spark.scheduler.SparkListenerInterface

    • onUnpersistRDD

      public void onUnpersistRDD(SparkListenerUnpersistRDD unpersistRDD)
      Specified by:
      onUnpersistRDD in interface org.apache.spark.scheduler.SparkListenerInterface

    • onUnschedulableTaskSetAdded

      public void onUnschedulableTaskSetAdded(SparkListenerUnschedulableTaskSetAdded unschedulableTaskSetAdded)
      Specified by:
      onUnschedulableTaskSetAdded in interface org.apache.spark.scheduler.SparkListenerInterface

    • onUnschedulableTaskSetRemoved

      public void onUnschedulableTaskSetRemoved(SparkListenerUnschedulableTaskSetRemoved unschedulableTaskSetRemoved)
      Specified by:
      onUnschedulableTaskSetRemoved in interface org.apache.spark.scheduler.SparkListenerInterface