tsdb.iterator

Class AbstractAggregationIterator

java.lang.Object

tsdb.util.iterator.TsIterator

tsdb.util.iterator.MoveIterator

tsdb.util.iterator.InputProcessingIterator

tsdb.iterator.AbstractAggregationIterator

All Implemented Interfaces:

java.util.Iterator<TsEntry>, ProcessingChainEntry, ProcessingChainNode, ProcessingChainSupplier

Direct Known Subclasses:

DayAggregationIterator, MonthAggregationIterator, WeekAggregationIterator, YearAggregationIterator

public abstract class AbstractAggregationIterator
extends InputProcessingIterator

Base class for aggregation iterators.

Field Summary

Fields

Modifier and Type	Field and Description
static int	QUALITY_COUNTER_POS_INTERPOLATED
static int	QUALITY_COUNTER_POS_VALUES
static int	QUALITY_COUNTERS

Fields inherited from class tsdb.util.iterator.InputProcessingIterator

input_iterator

Fields inherited from class tsdb.util.iterator.TsIterator

schema

Constructor Summary

Constructors

Constructor and Description
AbstractAggregationIterator(TsDB tsdb, TsIterator input_iterator, TsSchema output_schema)

Method Summary

Modifier and Type	Method and Description
protected abstract long	calcAggregationTimestamp(long timestamp)
protected static TsSchema	createSchemaConstantStep(TsSchema schema, int fromStep, int toStep)
protected static TsSchema	createSchemaFromConstantToVariableStep(TsSchema schema, int fromStep, TsSchema.Aggregation toAggregation)
protected static TsSchema	createSchemaVariableStep(TsSchema schema, TsSchema.Aggregation fromAggregation, TsSchema.Aggregation toAggregation)
protected abstract AggregationType[]	getAggregationTypes(Sensor[] sensors)
protected TsEntry	getNext() Request next element.
protected abstract boolean	isValidAggregate(int collectorCount, AggregationType aggregationType) checks if enough values have been collected for one aggregation unit

Methods inherited from class tsdb.util.iterator.InputProcessingIterator

getProcessingChain

Methods inherited from class tsdb.util.iterator.MoveIterator

close, hasNext, next

Methods inherited from class tsdb.util.iterator.TsIterator

getNames, getSchema, isLive, isNotLive, toSchemas, toString, toTimeSeries, toTimestampSeries, writeConsole, writeConsole, writeCSV

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

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

QUALITY_COUNTERS

public static final int QUALITY_COUNTERS

See Also:

Constant Field Values

QUALITY_COUNTER_POS_VALUES

public static final int QUALITY_COUNTER_POS_VALUES

See Also:

Constant Field Values

QUALITY_COUNTER_POS_INTERPOLATED

public static final int QUALITY_COUNTER_POS_INTERPOLATED

See Also:

Constant Field Values

Constructor Detail

AbstractAggregationIterator

public AbstractAggregationIterator(TsDB tsdb,
                                   TsIterator input_iterator,
                                   TsSchema output_schema)

Method Detail

createSchemaConstantStep

protected static TsSchema createSchemaConstantStep(TsSchema schema,
                                                   int fromStep,
                                                   int toStep)

createSchemaFromConstantToVariableStep

protected static TsSchema createSchemaFromConstantToVariableStep(TsSchema schema,
                                                                 int fromStep,
                                                                 TsSchema.Aggregation toAggregation)

createSchemaVariableStep

protected static TsSchema createSchemaVariableStep(TsSchema schema,
                                                   TsSchema.Aggregation fromAggregation,
                                                   TsSchema.Aggregation toAggregation)

getAggregationTypes

protected abstract AggregationType[] getAggregationTypes(Sensor[] sensors)

isValidAggregate

protected abstract boolean isValidAggregate(int collectorCount,
                                            AggregationType aggregationType)

checks if enough values have been collected for one aggregation unit

Parameters:

collectorCount -

aggregationType -

Returns:

calcAggregationTimestamp

protected abstract long calcAggregationTimestamp(long timestamp)

getNext

protected TsEntry getNext()

Description copied from class: MoveIterator

Request next element.

It's guaranteed to not be called again when it first returns null (no next element).
This method should be called by MoveIterator internal only.

Specified by:

getNext in class MoveIterator

Returns:

next element or null if there is no next element