tsdb.streamdb

Class StreamIterator

java.lang.Object

tsdb.streamdb.StreamIterator

All Implemented Interfaces:

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

public class StreamIterator
extends java.lang.Object
implements java.util.Iterator<DataEntry>, ProcessingChainNode

Iterator over one time series

Field Summary

Fields

Modifier and Type	Field and Description
int	maxQueryTimestamp
int	minQueryTimestamp
java.lang.String	sensorName
java.lang.String	stationName

Constructor Summary

Constructors

Constructor and Description
StreamIterator(SensorMeta sensorMeta, <any> chunkMetaMap, <any> sensorChunkMap, int minQueryTimestamp, int maxQueryTimestamp)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getProcessingTitle() Default implementation: Create title for processing chain entry from class name.
boolean	hasNext()
DataEntry	next()
DataEntry[]	remainingToArray()
java.lang.String	toString()

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

getProcessingChain

Methods inherited from interface tsdb.util.processingchain.ProcessingChainEntry

createUnknown, of

Methods inherited from interface tsdb.util.processingchain.ProcessingChainSupplier

createUnknown

Field Detail

minQueryTimestamp

public final int minQueryTimestamp

maxQueryTimestamp

public final int maxQueryTimestamp

stationName

public final java.lang.String stationName

sensorName

public final java.lang.String sensorName

Constructor Detail

StreamIterator

public StreamIterator(SensorMeta sensorMeta,
                      <any> chunkMetaMap,
                      <any> sensorChunkMap,
                      int minQueryTimestamp,
                      int maxQueryTimestamp)

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface java.util.Iterator<DataEntry>

next

public DataEntry next()

Specified by:

next in interface java.util.Iterator<DataEntry>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getProcessingTitle

public java.lang.String getProcessingTitle()

Description copied from interface: ProcessingChainNode

Default implementation: Create title for processing chain entry from class name.

Specified by:

getProcessingTitle in interface ProcessingChainEntry

Specified by:

getProcessingTitle in interface ProcessingChainNode

Returns:

remainingToArray

public DataEntry[] remainingToArray()