public class JobMetricsListener extends Object
Constructor and Description |
---|
JobMetricsListener() |
Modifier and Type | Method and Description |
---|---|
void |
cleanup(int jobId) |
Map<String,List<TaskMetrics>> |
getJobMetric(int jobId) |
void |
onApplicationEnd(SparkListenerApplicationEnd applicationEnd) |
void |
onApplicationStart(SparkListenerApplicationStart applicationStart) |
void |
onBlockManagerAdded(SparkListenerBlockManagerAdded blockManagerAdded) |
void |
onBlockManagerRemoved(SparkListenerBlockManagerRemoved blockManagerRemoved) |
void |
onBlockUpdated(SparkListenerBlockUpdated blockUpdated) |
void |
onEnvironmentUpdate(SparkListenerEnvironmentUpdate environmentUpdate) |
void |
onExecutorAdded(SparkListenerExecutorAdded executorAdded) |
void |
onExecutorMetricsUpdate(SparkListenerExecutorMetricsUpdate executorMetricsUpdate) |
void |
onExecutorRemoved(SparkListenerExecutorRemoved executorRemoved) |
void |
onJobEnd(SparkListenerJobEnd jobEnd) |
void |
onJobStart(SparkListenerJobStart jobStart) |
void |
onStageCompleted(SparkListenerStageCompleted stageCompleted) |
void |
onStageSubmitted(SparkListenerStageSubmitted stageSubmitted) |
void |
onTaskEnd(SparkListenerTaskEnd taskEnd) |
void |
onTaskGettingResult(SparkListenerTaskGettingResult taskGettingResult) |
void |
onTaskStart(SparkListenerTaskStart taskStart) |
void |
onUnpersistRDD(SparkListenerUnpersistRDD unpersistRDD) |
void |
reset() |
boolean |
waitForJobToEnd(int jobId) |
public void onStageCompleted(SparkListenerStageCompleted stageCompleted)
public void onStageSubmitted(SparkListenerStageSubmitted stageSubmitted)
public void onTaskStart(SparkListenerTaskStart taskStart)
public void onTaskGettingResult(SparkListenerTaskGettingResult taskGettingResult)
public void onExecutorRemoved(SparkListenerExecutorRemoved executorRemoved)
public void onExecutorAdded(SparkListenerExecutorAdded executorAdded)
public void onBlockUpdated(SparkListenerBlockUpdated blockUpdated)
public void onTaskEnd(SparkListenerTaskEnd taskEnd)
public void onJobStart(SparkListenerJobStart jobStart)
public void onJobEnd(SparkListenerJobEnd jobEnd)
public void onEnvironmentUpdate(SparkListenerEnvironmentUpdate environmentUpdate)
public void onBlockManagerAdded(SparkListenerBlockManagerAdded blockManagerAdded)
public void onBlockManagerRemoved(SparkListenerBlockManagerRemoved blockManagerRemoved)
public void onUnpersistRDD(SparkListenerUnpersistRDD unpersistRDD)
public void onApplicationStart(SparkListenerApplicationStart applicationStart)
public void onApplicationEnd(SparkListenerApplicationEnd applicationEnd)
public void onExecutorMetricsUpdate(SparkListenerExecutorMetricsUpdate executorMetricsUpdate)
public boolean waitForJobToEnd(int jobId) throws InterruptedException
InterruptedException
public void cleanup(int jobId)
public void reset()
Copyright © 2007-2017 The Apache Software Foundation