Constructor and Description |
---|
SparkReporter(SparkCounters sparkCounters) |
Modifier and Type | Method and Description |
---|---|
SparkStatisticsBuilder |
SparkStatisticsBuilder.add(SparkCounters sparkCounters) |
Modifier and Type | Method and Description |
---|---|
SparkCounters |
SparkJobStatus.getCounter() |
Modifier and Type | Method and Description |
---|---|
SparkCounters |
RemoteSparkJobStatus.getCounter() |
SparkCounters |
LocalSparkJobStatus.getCounter() |
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 |
---|---|
SparkCounters |
JobHandle.getSparkCounters()
Get the SparkCounters for this job.
|
Modifier and Type | Method and Description |
---|---|
<T> org.apache.spark.api.java.JavaFutureAction<T> |
JobContext.monitor(org.apache.spark.api.java.JavaFutureAction<T> job,
SparkCounters sparkCounters,
Set<Integer> cachedRDDIds)
Monitor a job.
|
Modifier and Type | Method and Description |
---|---|
SparkCounters |
SparkCounters.snapshot()
Create a snapshot of the current counters to send back to the client.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.