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

Class LocalSparkJobStatus

java.lang.Object

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

All Implemented Interfaces:

SparkJobStatus

public class LocalSparkJobStatus
extends Object
implements SparkJobStatus

Constructor Summary

Constructors

Constructor and Description
LocalSparkJobStatus(org.apache.spark.api.java.JavaSparkContext sparkContext, int jobId, JobMetricsListener jobMetricsListener, SparkCounters sparkCounters, Set<Integer> cachedRDDIds, org.apache.spark.api.java.JavaFutureAction<Void> future)

Method Summary

Modifier and Type	Method and Description
void	cleanup()
String	getAppID()
SparkCounters	getCounter()
Throwable	getError()
int	getJobId()
Map<String,SparkStageProgress>	getSparkStageProgress()
SparkStatistics	getSparkStatistics()
int[]	getStageIds()
org.apache.spark.JobExecutionStatus	getState()
String	getWebUIURL()
void	setError(Throwable e)

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalSparkJobStatus

public LocalSparkJobStatus(org.apache.spark.api.java.JavaSparkContext sparkContext,
                           int jobId,
                           JobMetricsListener jobMetricsListener,
                           SparkCounters sparkCounters,
                           Set<Integer> cachedRDDIds,
                           org.apache.spark.api.java.JavaFutureAction<Void> future)

Method Detail

getAppID

public String getAppID()

Specified by:

getAppID in interface SparkJobStatus

getJobId

public int getJobId()

Specified by:

getJobId in interface SparkJobStatus

getState

public org.apache.spark.JobExecutionStatus getState()

Specified by:

getState in interface SparkJobStatus

getStageIds

public int[] getStageIds()

Specified by:

getStageIds in interface SparkJobStatus

getSparkStageProgress

public Map<String,SparkStageProgress> getSparkStageProgress()

Specified by:

getSparkStageProgress in interface SparkJobStatus

getCounter

public SparkCounters getCounter()

Specified by:

getCounter in interface SparkJobStatus

getSparkStatistics

public SparkStatistics getSparkStatistics()

Specified by:

getSparkStatistics in interface SparkJobStatus

getWebUIURL

public String getWebUIURL()

Specified by:

getWebUIURL in interface SparkJobStatus

cleanup

public void cleanup()

Specified by:

cleanup in interface SparkJobStatus

getError

public Throwable getError()

Specified by:

getError in interface SparkJobStatus

setError

public void setError(Throwable e)

Specified by:

setError in interface SparkJobStatus