tsdb.util.iterator

Class TimeSeries

java.lang.Object

tsdb.util.iterator.TimeSeries

All Implemented Interfaces:

java.lang.Iterable<TsEntry>, TsIterable, ProcessingChainEntry, ProcessingChainNode, ProcessingChainSupplier

public class TimeSeries
extends java.lang.Object
implements TsIterable, ProcessingChainNode

Time series of aggregated data.

Time interval between values is constant

Field Summary

Fields

Modifier and Type	Field and Description
float[][]	data time series data values: data [ sensor index ] [ row index ]
boolean[][]	dataInterpolated
DataQuality[][]	dataQuality
boolean	hasDataInterpolatedFlag
boolean	hasDataQualityFlag
java.lang.String[]	parameterNames sensor names of time series in data
long	startTimestamp timestamp of first entry in data
int	timeStep constant time step between entries

Constructor Summary

Constructors

Constructor and Description
TimeSeries(ProcessingChainSupplier processingChainSupplier, java.lang.String[] parameterNames, long startTimestamp, int timeStep, float[][] data, DataQuality[][] dataQuality, boolean[][] dataInterpolated) Creates TimeSeries filled with data.

Method Summary

Modifier and Type	Method and Description
void	addToProcessingChain(ProcessingChainEntry entry)
void	addToProcessingChain(java.lang.String entry)
boolean	containsParamterName(java.lang.String parameterName)
static TimeSeries	create(TsIterator input_iterator) Converts elements of an iterator in TimeSeries object.
TsSchema	createSchema()
long	getFirstTimestamp() get timestamp of first data entry
boolean[]	getInterpolationFlags(java.lang.String parameterName)
long	getLastTimestamp() get timestamp of last data entry
int	getParameterNameIndex(java.lang.String parameterName) get position of sensor name in data array
ProcessingChain	getProcessingChain() Default implementation: Get processing chain with this as source entry.
float[]	getValues(java.lang.String parameterName) get one data column
TsIterator	timeSeriesIteratorCLIP(java.lang.Long clipStart, java.lang.Long clipEnd) Iterator of data from clipStart to clipEnd
static TimeSeries	toBaseTimeSeries(java.lang.Long startTimestamp, java.lang.Long endTimestamp, TimestampSeries timestampSeries) converts TimestampSeries to TimeSeries missing values before and after data in source time series and gaps within source timeseries are filled with NaN-values source time series needs to be aggregated already
java.lang.String	toString() some summary data of this time series
TsIterator	tsIterator()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface tsdb.util.iterator.TsIterable

iterator

Methods inherited from interface java.lang.Iterable

forEach, spliterator

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

Field Detail

parameterNames

public java.lang.String[] parameterNames

sensor names of time series in data

startTimestamp

public long startTimestamp

timestamp of first entry in data

timeStep

public final int timeStep

constant time step between entries

data

public float[][] data

time series data values: data [ sensor index ] [ row index ]

hasDataQualityFlag

public boolean hasDataQualityFlag

hasDataInterpolatedFlag

public boolean hasDataInterpolatedFlag

dataQuality

public DataQuality[][] dataQuality

dataInterpolated

public boolean[][] dataInterpolated

Constructor Detail

TimeSeries

public TimeSeries(ProcessingChainSupplier processingChainSupplier,
                  java.lang.String[] parameterNames,
                  long startTimestamp,
                  int timeStep,
                  float[][] data,
                  DataQuality[][] dataQuality,
                  boolean[][] dataInterpolated)

Creates TimeSeries filled with data.

Parameters:

processingChainSupplier - nullable

parameterNames - column names

startTimestamp - timestampm of first entry

timeStep - time step between entries

data - Array of data rows.

dataQuality - Array of data quality rows. nullable

dataInterpolated - Array of data interpolated flag rows. nullable

Method Detail

create

public static TimeSeries create(TsIterator input_iterator)

Converts elements of an iterator in TimeSeries object.

Elements need to be ordered in constant timeStep time intervals.

Parameters:

input_iterator -

Returns:

toBaseTimeSeries

public static TimeSeries toBaseTimeSeries(java.lang.Long startTimestamp,
                                          java.lang.Long endTimestamp,
                                          TimestampSeries timestampSeries)

converts TimestampSeries to TimeSeries missing values before and after data in source time series and gaps within source timeseries are filled with NaN-values source time series needs to be aggregated already

Parameters:

startTimestamp - timestamp of first entry in resulting time series

endTimestamp - timestamp of last entry in resulting time series

timestampSeries -

Returns:

null if conversion is not possible

toString

public java.lang.String toString()

some summary data of this time series

Overrides:

toString in class java.lang.Object

getParameterNameIndex

public int getParameterNameIndex(java.lang.String parameterName)

get position of sensor name in data array

Parameters:

parameterName -

Returns:

containsParamterName

public boolean containsParamterName(java.lang.String parameterName)

getValues

public float[] getValues(java.lang.String parameterName)

get one data column

Parameters:

parameterName -

Returns:

getInterpolationFlags

public boolean[] getInterpolationFlags(java.lang.String parameterName)

getFirstTimestamp

public long getFirstTimestamp()

get timestamp of first data entry

Returns:

getLastTimestamp

public long getLastTimestamp()

get timestamp of last data entry

Returns:

tsIterator

public TsIterator tsIterator()

Specified by:

tsIterator in interface TsIterable

timeSeriesIteratorCLIP

public TsIterator timeSeriesIteratorCLIP(java.lang.Long clipStart,
                                         java.lang.Long clipEnd)

Iterator of data from clipStart to clipEnd

Parameters:

clipStart - if null then from start

clipEnd - if null then up to end

Returns:

createSchema

public TsSchema createSchema()

getProcessingChain

public ProcessingChain getProcessingChain()

Description copied from interface: ProcessingChainNode

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

Specified by:

getProcessingChain in interface ProcessingChainNode

Specified by:

getProcessingChain in interface ProcessingChainSupplier

Returns:

addToProcessingChain

public void addToProcessingChain(java.lang.String entry)

addToProcessingChain

public void addToProcessingChain(ProcessingChainEntry entry)