tsdb.iterator

Class DayAggregationIterator

java.lang.Object

tsdb.util.iterator.TsIterator

tsdb.util.iterator.MoveIterator

tsdb.util.iterator.InputProcessingIterator

tsdb.iterator.AbstractAggregationIterator

tsdb.iterator.DayAggregationIterator

All Implemented Interfaces:

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

public class DayAggregationIterator
extends AbstractAggregationIterator

Aggregate hour data to day 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
DayAggregationIterator(TsDB tsdb, TsIterator input_iterator, Mutator dayMutator)

Method Summary

Modifier and Type	Method and Description
protected long	calcAggregationTimestamp(long timestamp)
protected AggregationType[]	getAggregationTypes(Sensor[] sensors)
protected TsEntry	getNext() Request next element.
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

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

DayAggregationIterator

public DayAggregationIterator(TsDB tsdb,
                              TsIterator input_iterator,
                              Mutator dayMutator)

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

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.

Overrides:

getNext in class AbstractAggregationIterator

Returns:

next element or null if there is no next element