public class Statistics extends Object
Modifier and Type | Field and Description |
---|---|
static org.apache.commons.logging.Log |
LOG |
Constructor and Description |
---|
Statistics(Configuration conf,
int pollingInterval,
CountDownLatch startFlag) |
Modifier and Type | Method and Description |
---|---|
void |
abort()
Shut down immediately, aborting any work in progress and discarding
all pending work.
|
void |
add(org.apache.hadoop.mapred.gridmix.Statistics.JobStats job)
Used by JobMonitor to add the completed job.
|
void |
addClusterStatsObservers(org.apache.hadoop.mapred.gridmix.StatListener<org.apache.hadoop.mapred.gridmix.Statistics.ClusterStats> listener) |
void |
addJobStats(org.apache.hadoop.mapred.gridmix.Statistics.JobStats stats)
Add a submitted job for monitoring.
|
void |
addJobStatsListeners(org.apache.hadoop.mapred.gridmix.StatListener<org.apache.hadoop.mapred.gridmix.Statistics.JobStats> listener) |
static org.apache.hadoop.mapred.gridmix.Statistics.JobStats |
generateJobStats(Job job,
JobStory jobdesc)
Generates a job stats.
|
void |
join(long millis)
Wait until the service completes.
|
void |
shutdown()
Shut down gracefully, finishing all pending work.
|
void |
start()
Attempt to start the service.
|
public Statistics(Configuration conf, int pollingInterval, CountDownLatch startFlag) throws IOException, InterruptedException
IOException
InterruptedException
public static org.apache.hadoop.mapred.gridmix.Statistics.JobStats generateJobStats(Job job, JobStory jobdesc)
public void addJobStats(org.apache.hadoop.mapred.gridmix.Statistics.JobStats stats)
public void add(org.apache.hadoop.mapred.gridmix.Statistics.JobStats job)
public void addClusterStatsObservers(org.apache.hadoop.mapred.gridmix.StatListener<org.apache.hadoop.mapred.gridmix.Statistics.ClusterStats> listener)
public void addJobStatsListeners(org.apache.hadoop.mapred.gridmix.StatListener<org.apache.hadoop.mapred.gridmix.Statistics.JobStats> listener)
public void start()
public void join(long millis) throws InterruptedException
shutdown
or abort()
has been requested.InterruptedException
public void shutdown()
public void abort()
Copyright © 2013 Apache Software Foundation. All rights reserved.