public abstract class AggregationJob extends Object
| Modifier and Type | Field and Description |
|---|---|
protected Aggregator |
aggregator |
| Constructor and Description |
|---|
AggregationJob(Aggregator aggregator)
constructor
|
| Modifier and Type | Method and Description |
|---|---|
Aggregator |
getAggregator() |
boolean |
isPreviouslyAttempted()
returns a boolean indicating whether or not this job has been attempted previously.
|
protected abstract void |
processAddedDataForSampleInterval(AggregationTimeBand timeBand)
called by the Aggregation infrastructure for a job to process the data held by its parent Aggregator
|
void |
run()
called by infrastructure for a job to process the data held by its parent Aggregator.
|
void |
setPreviouslyAttempted(boolean previouslyAttempted)
sets the flag on this AggregationJob to indicate that it has been previously attempted.
|
protected Aggregator aggregator
public AggregationJob(Aggregator aggregator)
protected abstract void processAddedDataForSampleInterval(AggregationTimeBand timeBand) throws AggregationException
timeBand - AggregationExceptionpublic void run()
throws AggregationException
AggregationExceptionpublic Aggregator getAggregator()
public boolean isPreviouslyAttempted()
public final void setPreviouslyAttempted(boolean previouslyAttempted)
© Copyright IBM Corp. 2013. All rights reserved.