org.apache.hadoop.hive.ql.exec.spark.status.impl

Class JobMetricsListener

java.lang.Object

org.apache.spark.scheduler.SparkListener

org.apache.hadoop.hive.ql.exec.spark.status.impl.JobMetricsListener

All Implemented Interfaces:

org.apache.spark.scheduler.SparkListenerInterface

public class JobMetricsListener
extends org.apache.spark.scheduler.SparkListener

Constructor Summary

Constructors

Constructor and Description
JobMetricsListener()

Method Summary

Modifier and Type	Method and Description
void	cleanup(int jobId)
Map<Integer,List<org.apache.spark.executor.TaskMetrics>>	getJobMetric(int jobId)
void	onJobStart(org.apache.spark.scheduler.SparkListenerJobStart jobStart)
void	onTaskEnd(org.apache.spark.scheduler.SparkListenerTaskEnd taskEnd)

Methods inherited from class org.apache.spark.scheduler.SparkListener

onApplicationEnd, onApplicationStart, onBlockManagerAdded, onBlockManagerRemoved, onBlockUpdated, onEnvironmentUpdate, onExecutorAdded, onExecutorMetricsUpdate, onExecutorRemoved, onJobEnd, onOtherEvent, onStageCompleted, onStageSubmitted, onTaskGettingResult, onTaskStart, onUnpersistRDD

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JobMetricsListener

public JobMetricsListener()

Method Detail

onTaskEnd

public void onTaskEnd(org.apache.spark.scheduler.SparkListenerTaskEnd taskEnd)

Specified by:

onTaskEnd in interface org.apache.spark.scheduler.SparkListenerInterface

Overrides:

onTaskEnd in class org.apache.spark.scheduler.SparkListener

onJobStart

public void onJobStart(org.apache.spark.scheduler.SparkListenerJobStart jobStart)

Specified by:

onJobStart in interface org.apache.spark.scheduler.SparkListenerInterface

Overrides:

onJobStart in class org.apache.spark.scheduler.SparkListener

getJobMetric

public Map<Integer,List<org.apache.spark.executor.TaskMetrics>> getJobMetric(int jobId)

cleanup

public void cleanup(int jobId)