public class LocalSparkJobStatus extends Object implements SparkJobStatus
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) |
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
String |
getAppID() |
SparkCounters |
getCounter() |
Throwable |
getError() |
int |
getJobId() |
Map<String,SparkStageProgress> |
getSparkStageProgress() |
SparkStatistics |
getSparkStatistics() |
int[] |
getStageIds() |
org.apache.spark.JobExecutionStatus |
getState() |
void |
setError(Throwable e) |
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)
public String getAppID()
getAppID
in interface SparkJobStatus
public int getJobId()
getJobId
in interface SparkJobStatus
public org.apache.spark.JobExecutionStatus getState()
getState
in interface SparkJobStatus
public int[] getStageIds()
getStageIds
in interface SparkJobStatus
public Map<String,SparkStageProgress> getSparkStageProgress()
getSparkStageProgress
in interface SparkJobStatus
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
Copyright © 2021 The Apache Software Foundation. All rights reserved.