tsdb.iterator

Class MergeIterator

java.lang.Object

tsdb.util.iterator.TsIterator

tsdb.util.iterator.MoveIterator

tsdb.iterator.MergeIterator

All Implemented Interfaces:

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

public class MergeIterator
extends MoveIterator

Merges multiple iterators into one by time stamp.

Field Summary

Fields inherited from class tsdb.util.iterator.TsIterator

schema

Constructor Summary

Constructors

Constructor and Description
MergeIterator(java.lang.String[] result_schema, java.util.Collection<TsIterator> input_iterator, java.lang.String debugTextplotID)
MergeIterator(java.lang.String[] result_schema, TsIterator[] input_iterator, java.lang.String debugTextplotID)

Method Summary

Modifier and Type	Method and Description
static TsSchema	createSchema(java.lang.String[] result_names, TsIterator[] input_iterator)
protected TsEntry	getNext() Request next element.
ProcessingChain	getProcessingChain() Default implementation: Get processing chain with this as source entry.

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

MergeIterator

public MergeIterator(java.lang.String[] result_schema,
                     java.util.Collection<TsIterator> input_iterator,
                     java.lang.String debugTextplotID)

MergeIterator

public MergeIterator(java.lang.String[] result_schema,
                     TsIterator[] input_iterator,
                     java.lang.String debugTextplotID)

Method Detail

createSchema

public static TsSchema createSchema(java.lang.String[] result_names,
                                    TsIterator[] input_iterator)

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.

Specified by:

getNext in class MoveIterator

Returns:

next element or null if there is no next element

getProcessingChain

public ProcessingChain getProcessingChain()

Description copied from interface: ProcessingChainNode

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

Returns: