public class RemoteSparkJobStatus extends Object implements SparkJobStatus
Constructor and Description |
---|
RemoteSparkJobStatus(SparkClient sparkClient,
JobHandle<Serializable> jobHandle,
long timeoutInSeconds) |
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() |
boolean |
isRemoteActive()
Indicates whether the remote context is active.
|
void |
setError(Throwable e) |
public RemoteSparkJobStatus(SparkClient sparkClient, JobHandle<Serializable> jobHandle, long timeoutInSeconds)
public String getAppID()
getAppID
in interface SparkJobStatus
public int getJobId()
getJobId
in interface SparkJobStatus
public org.apache.spark.JobExecutionStatus getState() throws HiveException
getState
in interface SparkJobStatus
HiveException
public int[] getStageIds() throws HiveException
getStageIds
in interface SparkJobStatus
HiveException
public Map<String,SparkStageProgress> getSparkStageProgress() throws HiveException
getSparkStageProgress
in interface SparkJobStatus
HiveException
public SparkCounters getCounter()
getCounter
in interface SparkJobStatus
public SparkStatistics getSparkStatistics()
getSparkStatistics
in interface SparkJobStatus
public void cleanup()
cleanup
in interface SparkJobStatus
public Throwable getError()
getError
in interface SparkJobStatus
public void setError(Throwable e)
setError
in interface SparkJobStatus
public boolean isRemoteActive()
public JobHandle.State getRemoteJobState()
Copyright © 2021 The Apache Software Foundation. All rights reserved.