public class StatisticsImpl extends Object implements Statistics
Constructor and Description |
---|
StatisticsImpl() |
StatisticsImpl(long startTime) |
Modifier and Type | Method and Description |
---|---|
void |
add(StatisticsImpl other)
Add another statistics information.
|
void |
addActive(long queueTime)
Add a job from the queue to status active
|
void |
cancelledJob()
Add a cancelled job.
|
void |
clearQueued()
Clear all queued
|
void |
copyFrom(StatisticsImpl other)
Create a new statistics object with exactly the same values.
|
void |
decQueued()
Job not processed by us
|
void |
failedJob()
Add a failed job.
|
void |
finishedJob(long jobTime)
Add a finished job
|
long |
getAverageProcessingTime()
The average processing time of a job - this only counts finished jobs.
|
long |
getAverageWaitingTime()
The average waiting time of a job in the queue.
|
long |
getLastActivatedJobTime()
The time a job has been started last.
|
long |
getLastFinishedJobTime()
The time a job has been finished/failed/cancelled last.
|
long |
getNumberOfActiveJobs()
Number of jobs currently in processing.
|
long |
getNumberOfCancelledJobs()
Number of permanently failing or cancelled jobs.
|
long |
getNumberOfFailedJobs()
Number of failing jobs.
|
long |
getNumberOfFinishedJobs()
Number of successfully finished jobs.
|
long |
getNumberOfJobs()
This just adds
Statistics.getNumberOfActiveJobs() and Statistics.getNumberOfQueuedJobs() |
long |
getNumberOfProcessedJobs()
Number of already processed jobs.
|
long |
getNumberOfQueuedJobs()
Number of jobs currently waiting in a queue.
|
long |
getStartTime()
The time this service has been started
|
void |
incQueued()
New job in the queue
|
void |
reset()
Clear all collected statistics and set the starting time to the current time.
|
public StatisticsImpl()
public StatisticsImpl(long startTime)
public long getStartTime()
Statistics
getStartTime
in interface Statistics
Statistics.getStartTime()
public long getNumberOfProcessedJobs()
Statistics
Statistics.getNumberOfFinishedJobs()
, Statistics.getNumberOfCancelledJobs()
and Statistics.getNumberOfFailedJobs()
getNumberOfProcessedJobs
in interface Statistics
Statistics.getNumberOfProcessedJobs()
public long getNumberOfActiveJobs()
Statistics
getNumberOfActiveJobs
in interface Statistics
Statistics.getNumberOfActiveJobs()
public long getNumberOfQueuedJobs()
Statistics
getNumberOfQueuedJobs
in interface Statistics
Statistics.getNumberOfQueuedJobs()
public long getNumberOfJobs()
Statistics
Statistics.getNumberOfActiveJobs()
and Statistics.getNumberOfQueuedJobs()
getNumberOfJobs
in interface Statistics
Statistics.getNumberOfJobs()
public long getAverageWaitingTime()
Statistics
getAverageWaitingTime
in interface Statistics
Statistics.getAverageWaitingTime()
public long getAverageProcessingTime()
Statistics
getAverageProcessingTime
in interface Statistics
Statistics.getAverageProcessingTime()
public long getNumberOfFinishedJobs()
Statistics
getNumberOfFinishedJobs
in interface Statistics
Statistics.getNumberOfFinishedJobs()
public long getNumberOfCancelledJobs()
Statistics
getNumberOfCancelledJobs
in interface Statistics
Statistics.getNumberOfCancelledJobs()
public long getNumberOfFailedJobs()
Statistics
getNumberOfFailedJobs
in interface Statistics
Statistics.getNumberOfFailedJobs()
public long getLastActivatedJobTime()
Statistics
getLastActivatedJobTime
in interface Statistics
Statistics.getLastActivatedJobTime()
public long getLastFinishedJobTime()
Statistics
getLastFinishedJobTime
in interface Statistics
Statistics.getLastFinishedJobTime()
public void finishedJob(long jobTime)
jobTime
- The processing time for this job.public void failedJob()
public void cancelledJob()
public void incQueued()
public void decQueued()
public void clearQueued()
public void addActive(long queueTime)
queueTime
- The time the job stayed in the queue.public void add(StatisticsImpl other)
public void copyFrom(StatisticsImpl other)
public void reset()
Statistics
reset
in interface Statistics
Statistics.reset()
Copyright © 2007–2015 The Apache Software Foundation. All rights reserved.