tsdb.streamdb

Class StreamTsIterator

java.lang.Object

tsdb.util.iterator.TsIterator

tsdb.streamdb.StreamTsIterator

All Implemented Interfaces:

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

public class StreamTsIterator
extends TsIterator

converts StreamIterator (or other DataEntry Iterator) to TsIterator

Field Summary

Fields inherited from class tsdb.util.iterator.TsIterator

schema

Constructor Summary

Constructors

Constructor and Description
StreamTsIterator(java.util.Iterator<DataEntry> input_iterator, java.lang.String sensorName)
StreamTsIterator(StreamIterator input_iterator)

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
TsEntry	next()
static StreamTsIterator	of(StreamIterator input_iterator)

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

getProcessingChain, getProcessingTitle

Methods inherited from interface tsdb.util.processingchain.ProcessingChainEntry

createUnknown, of

Methods inherited from interface tsdb.util.processingchain.ProcessingChainSupplier

createUnknown

Constructor Detail

StreamTsIterator

public StreamTsIterator(StreamIterator input_iterator)

StreamTsIterator

public StreamTsIterator(java.util.Iterator<DataEntry> input_iterator,
                        java.lang.String sensorName)

Method Detail

of

public static StreamTsIterator of(StreamIterator input_iterator)

hasNext

public boolean hasNext()

next

public TsEntry next()