tsdb.util.iterator

Class TsIteratorIterator

java.lang.Object

tsdb.util.iterator.TsIterator

tsdb.util.iterator.MoveIterator

tsdb.util.iterator.TsIteratorIterator

All Implemented Interfaces:

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

public class TsIteratorIterator
extends MoveIterator

Concatenates elements of several input iterators.

Timestamps are not checked. Elements are produced in order of input iterators. So timestamps may not be ascending.

Field Summary

Fields inherited from class tsdb.util.iterator.TsIterator

schema

Constructor Summary

Constructors

Constructor and Description
TsIteratorIterator(java.lang.Iterable<TsIterator> input, java.lang.String[] outputSchema) Creates concatenated of collection of inputs
TsIteratorIterator(java.util.Iterator<TsIterator> input_iterator, java.lang.String[] outputSchema) Creates concatenated of collection of inputs

Method Summary

Modifier and Type	Method and Description
static <T> TsIteratorIterator	create(java.lang.Iterable<T> input, java.util.function.Function<T,TsIterator> function) Creates concatenated of collection of inputs.
static <T> TsIteratorIterator	create(java.util.Iterator<T> input_iterator, java.util.function.Function<T,TsIterator> function) Creates concatenated of collection of inputs Column names of iterator is union of column names of input iterators.
protected TsEntry	getNext() Request next element.

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

getProcessingChain, getProcessingTitle

Methods inherited from interface tsdb.util.processingchain.ProcessingChainEntry

createUnknown, of

Methods inherited from interface tsdb.util.processingchain.ProcessingChainSupplier

createUnknown

Constructor Detail

TsIteratorIterator

public TsIteratorIterator(java.lang.Iterable<TsIterator> input,
                          java.lang.String[] outputSchema)

Creates concatenated of collection of inputs

Parameters:

input - collection of input iterators

outputSchema - schema of iterator

TsIteratorIterator

public TsIteratorIterator(java.util.Iterator<TsIterator> input_iterator,
                          java.lang.String[] outputSchema)

Creates concatenated of collection of inputs

Parameters:

input_iterator - iterator over input iterators

outputSchema - schema of iterator

Method Detail

create

public static <T> TsIteratorIterator create(java.lang.Iterable<T> input,
                                            java.util.function.Function<T,TsIterator> function)

Creates concatenated of collection of inputs.

Column names of iterator is union of column names of input iterators.

Parameters:

input - source objects

function - mapping to iterator

Returns:

create

public static <T> TsIteratorIterator create(java.util.Iterator<T> input_iterator,
                                            java.util.function.Function<T,TsIterator> function)

Creates concatenated of collection of inputs

Column names of iterator is union of column names of input iterators.

Parameters:

input - iterator over source objects

function - mapping to iterator

Returns:

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