tsdb.graph.processing

Class Aggregated

java.lang.Object

tsdb.graph.node.Continuous.Abstract

tsdb.graph.processing.Aggregated

All Implemented Interfaces:

Continuous, Node

public class Aggregated
extends Continuous.Abstract

This node creates aggregated data from continuous input data. Depending on the requested aggregation interval a hierarchy of aggregation iterators will be created.

Nested Class Summary

Nested classes/interfaces inherited from interface tsdb.graph.node.Continuous

Continuous.Abstract, Continuous.Concrete

Field Summary

Fields inherited from class tsdb.graph.node.Continuous.Abstract

tsdb

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Aggregated(TsDB tsdb, Continuous source, AggregationInterval aggregationInterval, Mutator dayMutator)

Method Summary

Modifier and Type	Method and Description
TsIterator	get(java.lang.Long start, java.lang.Long end)
TsIterator	getExactly(long start, long end) create an iterator with values filling the interval (start, end), missing timestamps are created with nan values
java.lang.String[]	getSchema()
Station	getSourceStation()
VirtualPlot	getSourceVirtualPlot()
long[]	getTimestampInterval()
boolean	isConstantTimestep() data stream aligned to time step
boolean	isContinuous() true => no time gaps in data stream, time steps do not need to be constant
static Aggregated	of(TsDB tsdb, Continuous source, AggregationInterval aggregationInterval, Mutator dayMutator)

Methods inherited from class java.lang.Object

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

Methods inherited from interface tsdb.graph.node.Continuous

of

Methods inherited from interface tsdb.graph.node.Node

getSourceName, getSourcePlot, getTimestampBaseInterval, writeConsole, writeConsole, writeCSV

Constructor Detail

Aggregated

protected Aggregated(TsDB tsdb,
                     Continuous source,
                     AggregationInterval aggregationInterval,
                     Mutator dayMutator)

Method Detail

of

public static Aggregated of(TsDB tsdb,
                            Continuous source,
                            AggregationInterval aggregationInterval,
                            Mutator dayMutator)

get

public TsIterator get(java.lang.Long start,
                      java.lang.Long end)

getSourceStation

public Station getSourceStation()

getSchema

public java.lang.String[] getSchema()

getExactly

public TsIterator getExactly(long start,
                             long end)

Description copied from interface: Continuous

create an iterator with values filling the interval (start, end), missing timestamps are created with nan values

Returns:

isContinuous

public boolean isContinuous()

Description copied from interface: Node

true => no time gaps in data stream, time steps do not need to be constant

Returns:

isConstantTimestep

public boolean isConstantTimestep()

Description copied from interface: Node

data stream aligned to time step

Returns:

getSourceVirtualPlot

public VirtualPlot getSourceVirtualPlot()

getTimestampInterval

public long[] getTimestampInterval()