tsdb.iterator

Class InterpolationAverageLinearIterator

java.lang.Object

tsdb.util.iterator.TsIterator

tsdb.util.iterator.InputIterator

tsdb.iterator.InterpolationAverageLinearIterator

All Implemented Interfaces:

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

public class InterpolationAverageLinearIterator
extends InputIterator

Interpolates missing data values in iterator with interpolated data from other iterators with avarege of multiple linear regressions.

Field Summary

Fields inherited from class tsdb.util.iterator.InputIterator

input_iterator

Fields inherited from class tsdb.util.iterator.TsIterator

schema

Constructor Summary

Constructors

Constructor and Description
InterpolationAverageLinearIterator(TsIterator input_iterator, TsIterator[] interpolationIterators, double[][] intercepts, double[][] slopes, java.lang.String[] interpolationSchema, double[][] weights) Creates interpolation iterator.

Method Summary

Modifier and Type	Method and Description
TsEntry	next()

Methods inherited from class tsdb.util.iterator.InputIterator

getProcessingChain, hasNext

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

InterpolationAverageLinearIterator

public InterpolationAverageLinearIterator(TsIterator input_iterator,
                                          TsIterator[] interpolationIterators,
                                          double[][] intercepts,
                                          double[][] slopes,
                                          java.lang.String[] interpolationSchema,
                                          double[][] weights)

Creates interpolation iterator.

Parameters:

input_iterator - source data entry of which missing data should be filled.

interpolationIterators - Array of reference iterators.

intercepts - Array of intercepts to reference iterators from linear regression for each column in interpolationSchema.
intercept == intercepts[interpolationIteratorNo][interpolationSchemaNo]

slopes - Array of slopes to reference iterators from linear regression for each column in interpolationSchema.
slope == slopes[interpolationIteratorNo][interpolationSchemaNo]

interpolationSchema - Array of column names that should be interpolated.

weights -

Method Detail

next

public TsEntry next()