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

Methods

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

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

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

cleanup

public void cleanup()

Specified by:

cleanup in interface SparkJobStatus