tsdb.util.iterator

Class TsIterator

java.lang.Object

tsdb.util.iterator.TsIterator

All Implemented Interfaces:

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

Direct Known Subclasses:

CSVIterator, DifferenceIterator, EmpiricalIterator, InputIterator, MoveIterator, RelationalIterator, StreamTsIterator, TimeSeriesEntryIterator

public abstract class TsIterator
extends java.lang.Object
implements java.util.Iterator<TsEntry>, ProcessingChainNode

Base iterator for time series data.

It contains meta data with schema and processing chain for information purposes.

Field Summary

Fields

Modifier and Type	Field and Description
protected TsSchema	schema Meta data as schema.

Constructor Summary

Constructors

Constructor and Description
TsIterator(TsSchema schema) Create iterator with schema.

Method Summary

Modifier and Type	Method and Description
java.lang.String[]	getNames() Get data schema names (column names).
TsSchema	getSchema() Get schema (meta data).
static boolean	isLive(java.util.Iterator<?> it) Check if iterator contains elements.
static boolean	isNotLive(java.util.Iterator<?> it) Check if iterator does not contain elements.
static TsSchema[]	toSchemas(TsIterator[] input_iterators) Get array of schemas from array of iterators.
java.lang.String	toString() Get Text of title, schema names and processing chain.
TimeSeries	toTimeSeries() Collect all remaining elements into TimeSeries Object.
TimestampSeries	toTimestampSeries(java.lang.String name) Collect all remaining elements into TimestampSeries Object.
void	writeConsole() Write all remaining elements to console.
void	writeConsole(int n) Write (at most) next n elements to console.
void	writeCSV(java.lang.String filename) Write all remaining elements to CSV-file.

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, hasNext, next, 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

Field Detail

schema

protected final TsSchema schema

Meta data as schema.

Constructor Detail

TsIterator

public TsIterator(TsSchema schema)

Create iterator with schema.

Parameters:

schema -

Method Detail

getSchema

public TsSchema getSchema()

Get schema (meta data).

Returns:

getNames

public java.lang.String[] getNames()

Get data schema names (column names).

Returns:

toString

public java.lang.String toString()

Get Text of title, schema names and processing chain.

Overrides:

toString in class java.lang.Object

writeCSV

public void writeCSV(java.lang.String filename)

Write all remaining elements to CSV-file.

Parameters:

filename -

writeConsole

public void writeConsole()

Write all remaining elements to console.

Parameters:

filename -

writeConsole

public void writeConsole(int n)

Write (at most) next n elements to console.

Parameters:

filename -

toTimeSeries

public TimeSeries toTimeSeries()

Collect all remaining elements into TimeSeries Object.

Parameters:

filename -

toTimestampSeries

public TimestampSeries toTimestampSeries(java.lang.String name)

Collect all remaining elements into TimestampSeries Object.

Parameters:

filename -

toSchemas

public static TsSchema[] toSchemas(TsIterator[] input_iterators)

Get array of schemas from array of iterators.

Parameters:

input_iterators -

Returns:

isLive

public static boolean isLive(java.util.Iterator<?> it)

Check if iterator contains elements.

Parameters:

it - (nullable)

Returns:

isNotLive

public static boolean isNotLive(java.util.Iterator<?> it)

Check if iterator does not contain elements.

Parameters:

it - (nullable)

Returns: