public class SparkFirehoseListener
extends Object
Constructor and Description |
---|
SparkFirehoseListener() |
public void onEvent(SparkListenerEvent event)
public final void onStageCompleted(SparkListenerStageCompleted stageCompleted)
public final void onStageSubmitted(SparkListenerStageSubmitted stageSubmitted)
public final void onTaskStart(SparkListenerTaskStart taskStart)
public final void onTaskGettingResult(SparkListenerTaskGettingResult taskGettingResult)
public final void onTaskEnd(SparkListenerTaskEnd taskEnd)
public final void onJobStart(SparkListenerJobStart jobStart)
public final void onJobEnd(SparkListenerJobEnd jobEnd)
public final void onEnvironmentUpdate(SparkListenerEnvironmentUpdate environmentUpdate)
public final void onBlockManagerAdded(SparkListenerBlockManagerAdded blockManagerAdded)
public final void onBlockManagerRemoved(SparkListenerBlockManagerRemoved blockManagerRemoved)
public final void onUnpersistRDD(SparkListenerUnpersistRDD unpersistRDD)
public final void onApplicationStart(SparkListenerApplicationStart applicationStart)
public final void onApplicationEnd(SparkListenerApplicationEnd applicationEnd)
public final void onExecutorMetricsUpdate(SparkListenerExecutorMetricsUpdate executorMetricsUpdate)
public final void onExecutorAdded(SparkListenerExecutorAdded executorAdded)
public final void onExecutorRemoved(SparkListenerExecutorRemoved executorRemoved)
public final void onExecutorBlacklisted(SparkListenerExecutorBlacklisted executorBlacklisted)
public final void onExecutorUnblacklisted(SparkListenerExecutorUnblacklisted executorUnblacklisted)
public final void onNodeBlacklisted(SparkListenerNodeBlacklisted nodeBlacklisted)
public final void onNodeUnblacklisted(SparkListenerNodeUnblacklisted nodeUnblacklisted)
public void onBlockUpdated(SparkListenerBlockUpdated blockUpdated)
public void onSpeculativeTaskSubmitted(SparkListenerSpeculativeTaskSubmitted speculativeTask)
public void onOtherEvent(SparkListenerEvent event)