public interface SparkJobStatus
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
String |
getAppID() |
SparkCounters |
getCounter() |
int |
getJobId() |
Map<String,SparkStageProgress> |
getSparkStageProgress() |
SparkStatistics |
getSparkStatistics() |
int[] |
getStageIds() |
org.apache.spark.JobExecutionStatus |
getState() |
String getAppID()
int getJobId()
org.apache.spark.JobExecutionStatus getState() throws HiveException
HiveException
int[] getStageIds() throws HiveException
HiveException
Map<String,SparkStageProgress> getSparkStageProgress() throws HiveException
HiveException
SparkCounters getCounter()
SparkStatistics getSparkStatistics()
void cleanup()
Copyright © 2016 The Apache Software Foundation. All rights reserved.