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
- AggregationException
public void run() throws AggregationException
AggregationException
public Aggregator getAggregator()
public boolean isPreviouslyAttempted()
public final void setPreviouslyAttempted(boolean previouslyAttempted)
© Copyright IBM Corp. 2013. All rights reserved.