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

Modifier and Type	Method and Description
void	cleanup()
String	getAppID()
SparkCounters	getCounter()
Throwable	getError()
int	getJobId()
JobHandle.State	getRemoteJobState()
Map<String,SparkStageProgress>	getSparkStageProgress()
SparkStatistics	getSparkStatistics()
int[]	getStageIds()
org.apache.spark.JobExecutionStatus	getState()
String	getWebUIURL()
boolean	isRemoteActive() Indicates whether the remote context is active.
void	setError(Throwable e)

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

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()
                                             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

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

isRemoteActive

public boolean isRemoteActive()

Indicates whether the remote context is active. SparkJobMonitor can use this to decide whether to stop monitoring.

getRemoteJobState

public JobHandle.State getRemoteJobState()