org.apache.pig.backend.hadoop.executionengine.spark

Class JobStatisticCollector

java.lang.Object

org.apache.pig.backend.hadoop.executionengine.spark.JobStatisticCollector

public class JobStatisticCollector
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
JobStatisticCollector()

Method Summary

Modifier and Type	Method and Description
void	cleanup(int jobId)
java.util.Map<java.lang.String,java.util.List<TaskMetrics>>	getJobMetric(int jobId)
SparkListener	getSparkListener()
void	reset()
void	waitForJobToEnd(int jobId)

Methods inherited from class java.lang.Object

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

Constructor Detail

JobStatisticCollector

public JobStatisticCollector()

Method Detail

getSparkListener

public SparkListener getSparkListener()

getJobMetric

public java.util.Map<java.lang.String,java.util.List<TaskMetrics>> getJobMetric(int jobId)

waitForJobToEnd

public void waitForJobToEnd(int jobId)
                     throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

cleanup

public void cleanup(int jobId)

reset

public void reset()