tsdb.iterator

Class AbstractCollectingAggregator

java.lang.Object

tsdb.iterator.AbstractCollectingAggregator

All Implemented Interfaces:

CollectingAggregator, ProcessingChainEntry, ProcessingChainNode, ProcessingChainSupplier

Direct Known Subclasses:

MonthCollectingAggregator, WeekCollectingAggregator, YearCollectingAggregator

public abstract class AbstractCollectingAggregator
extends java.lang.Object
implements CollectingAggregator

Base class for collecting aggregators

Field Summary

Fields

Modifier and Type	Field and Description
int[]	outputCounters
java.util.ArrayList<java.lang.Float>[]	outputs
long	outputTimestamp

Constructor Summary

Constructors

Constructor and Description
AbstractCollectingAggregator(CollectingAggregator collectingAggregator, int estimatedAggregationCapacity)

Method Summary

Modifier and Type	Method and Description
protected abstract long	calcAggregationTimestamp(long timestamp)
long	calcNextOutput()
int	getAttributeCount()
java.util.ArrayList<java.lang.Float>[]	getOutputs()
ProcessingChain	getProcessingChain() Default implementation: Get processing chain with this as source entry.
protected abstract boolean	isValidAggregate(int collectorCount, AggregationType aggregationType)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface tsdb.util.processingchain.ProcessingChainNode

getProcessingTitle

Methods inherited from interface tsdb.util.processingchain.ProcessingChainEntry

createUnknown, of

Methods inherited from interface tsdb.util.processingchain.ProcessingChainSupplier

createUnknown

Field Detail

outputs

public final java.util.ArrayList<java.lang.Float>[] outputs

outputCounters

public final int[] outputCounters

outputTimestamp

public long outputTimestamp

Constructor Detail

AbstractCollectingAggregator

public AbstractCollectingAggregator(CollectingAggregator collectingAggregator,
                                    int estimatedAggregationCapacity)

Method Detail

calcNextOutput

public long calcNextOutput()

Specified by:

calcNextOutput in interface CollectingAggregator

calcAggregationTimestamp

protected abstract long calcAggregationTimestamp(long timestamp)

isValidAggregate

protected abstract boolean isValidAggregate(int collectorCount,
                                            AggregationType aggregationType)

getOutputs

public java.util.ArrayList<java.lang.Float>[] getOutputs()

Specified by:

getOutputs in interface CollectingAggregator

getAttributeCount

public int getAttributeCount()

Specified by:

getAttributeCount in interface CollectingAggregator

getProcessingChain

public ProcessingChain getProcessingChain()

Description copied from interface: ProcessingChainNode

Default implementation: Get processing chain with this as source entry.

Specified by:

getProcessingChain in interface ProcessingChainNode

Specified by:

getProcessingChain in interface ProcessingChainSupplier

Returns: