tsdb.iterator

Class YearAggregationIterator

java.lang.Object

tsdb.util.iterator.TsIterator

tsdb.util.iterator.MoveIterator

tsdb.util.iterator.InputProcessingIterator

tsdb.iterator.AbstractAggregationIterator

tsdb.iterator.YearAggregationIterator

All Implemented Interfaces:

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

public class YearAggregationIterator
extends AbstractAggregationIterator

Aggregate month data to year data.

Field Summary

Fields inherited from class tsdb.iterator.AbstractAggregationIterator

QUALITY_COUNTER_POS_INTERPOLATED, QUALITY_COUNTER_POS_VALUES, 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
YearAggregationIterator(TsDB tsdb, TsIterator input_iterator)

Method Summary

Modifier and Type	Method and Description
protected long	calcAggregationTimestamp(long timestamp)
protected AggregationType[]	getAggregationTypes(Sensor[] sensors)
protected boolean	isValidAggregate(int collectorCount, AggregationType aggregationType) checks if enough values have been collected for one aggregation unit

Methods inherited from class tsdb.iterator.AbstractAggregationIterator

createSchemaConstantStep, createSchemaFromConstantToVariableStep, createSchemaVariableStep, getNext

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

Constructor Detail

YearAggregationIterator

public YearAggregationIterator(TsDB tsdb,
                               TsIterator input_iterator)

Method Detail

calcAggregationTimestamp

protected long calcAggregationTimestamp(long timestamp)

Specified by:

calcAggregationTimestamp in class AbstractAggregationIterator

isValidAggregate

protected boolean isValidAggregate(int collectorCount,
                                   AggregationType aggregationType)

Description copied from class: AbstractAggregationIterator

checks if enough values have been collected for one aggregation unit

Specified by:

isValidAggregate in class AbstractAggregationIterator

Returns:

getAggregationTypes

protected AggregationType[] getAggregationTypes(Sensor[] sensors)

Specified by:

getAggregationTypes in class AbstractAggregationIterator