tsdb.iterator

Class EmpiricalIterator

java.lang.Object

tsdb.util.iterator.TsIterator

tsdb.iterator.EmpiricalIterator

All Implemented Interfaces:

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

public class EmpiricalIterator
extends TsIterator

This iterator checks values of input_iterator by comparing values to compare_iterator. If value is higher than maxDiff a nan value is inserted.

Field Summary

Fields inherited from class tsdb.util.iterator.TsIterator

schema

Constructor Summary

Constructors

Constructor and Description
EmpiricalIterator(TsIterator input_iterator, TsIterator compare_iterator, java.lang.Float[] maxDiff, float[] refValues)

Method Summary

Modifier and Type	Method and Description
static TsSchema	createSchema(TsSchema schema)
ProcessingChain	getProcessingChain() Default implementation: Get processing chain with this as source entry.
boolean	hasNext()
TsEntry	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

EmpiricalIterator

public EmpiricalIterator(TsIterator input_iterator,
                         TsIterator compare_iterator,
                         java.lang.Float[] maxDiff,
                         float[] refValues)

Method Detail

createSchema

public static TsSchema createSchema(TsSchema schema)

hasNext

public boolean hasNext()

next

public TsEntry next()

getProcessingChain

public ProcessingChain getProcessingChain()

Description copied from interface: ProcessingChainNode

Default implementation: Get processing chain with this as source entry.

Returns: