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

Class RemoteSparkJobStatus

java.lang.Object

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

All Implemented Interfaces:

SparkJobStatus

public class RemoteSparkJobStatus
extends Object
implements SparkJobStatus

Used with remove spark client.

Constructor Summary

Constructors

Constructor and Description
RemoteSparkJobStatus(SparkClient sparkClient, JobHandle<Serializable> jobHandle, long timeoutInSeconds)

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup()
SparkCounters	getCounter()
int	getJobId()
JobHandle.State	getRemoteJobState()
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

RemoteSparkJobStatus

public RemoteSparkJobStatus(SparkClient sparkClient,
                    JobHandle<Serializable> jobHandle,
                    long timeoutInSeconds)

Method Detail

getJobId

public int getJobId()

Specified by:

getJobId in interface SparkJobStatus

getState

public org.apache.spark.JobExecutionStatus getState()
                                             throws HiveException

Specified by:

getState in interface SparkJobStatus

Throws:

HiveException

getStageIds

public int[] getStageIds()
                  throws HiveException

Specified by:

getStageIds in interface SparkJobStatus

Throws:

HiveException

getSparkStageProgress

public Map<String,SparkStageProgress> getSparkStageProgress()
                                                     throws HiveException

Specified by:

getSparkStageProgress in interface SparkJobStatus

Throws:

HiveException

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

getRemoteJobState

public JobHandle.State getRemoteJobState()