DataPipe
, DataPipeForked
, IDataSink
, IDataSource
AccumulatorRatioAverageCovariance
, AccumulatorRatioAverageCovarianceFull
public class AccumulatorAverageCovariance extends AccumulatorAverageFixed
AccumulatorAverage.StatType
Modifier and Type | Field | Description |
---|---|---|
static AccumulatorAverage.StatType |
BLOCK_COVARIANCE |
|
protected DataDoubleArray |
blockCovariance |
|
protected DataDoubleArray |
blockCovSum |
|
protected DataDoubleArray |
covariance |
|
static AccumulatorAverage.StatType |
COVARIANCE |
|
protected DataDoubleArray |
covSum |
|
protected boolean |
fullCovariance |
average, AVERAGE, BLOCK_CORRELATION, blockCorrelation, blockCountDown, blockSize, count, dataGroup, doIncludeACInError, error, ERROR, MOST_RECENT, mostRecent, STANDARD_DEVIATION, standardDeviation
blockDataSink, blockFilename, blockVarSum, correlationSum, currentBlockAvg, firstBlock, mostRecentBlock, negativeChop, numSavedBlockData, sanityCheckBC, savedBlockData, sumSquare, work, work2
active, hasUnpushedData, pushInterval, putCount
dataInfo, dataSink, tag
Constructor | Description |
---|---|
AccumulatorAverageCovariance() |
|
AccumulatorAverageCovariance(boolean fullCovariance) |
|
AccumulatorAverageCovariance(long blockSize) |
|
AccumulatorAverageCovariance(long blockSize,
boolean fullCovariance) |
Modifier and Type | Method | Description |
---|---|---|
boolean |
addData(IData data) |
Add the given values to the sums and block sums.
|
protected void |
doBlockSum() |
Performs the block sum after blockSize calls to addData.
|
IData |
getData() |
|
IDataInfo |
processDataInfo(IDataInfo incomingDataInfo) |
Prepares the accumulator for input data.
|
void |
reset() |
Resets all sums to zero.
|
static AccumulatorAverage.StatType[] |
statChoices() |
addDataSink, doIncludeACInError, getBlockCount, getBlockSize, getData, getSampleCount, getTag, setBlockSize, setIncludeACInError
getBlockDataSink, getDoStrictBlockData, putDataInfo, readBlockData, setBlockDataSink, setWriteBlocks, writeBlockData
getPushInterval, isActive, processData, setActive, setPushInterval, toString
getDataInfo, getTag, putData
addDataSink, getDataSink, getDataSinks, removeDataSink, setDataSink, setDataSinks
getDataInfo, getTag
public static final AccumulatorAverage.StatType COVARIANCE
public static final AccumulatorAverage.StatType BLOCK_COVARIANCE
protected DataDoubleArray covSum
protected DataDoubleArray blockCovSum
protected DataDoubleArray covariance
protected DataDoubleArray blockCovariance
protected final boolean fullCovariance
public AccumulatorAverageCovariance()
public AccumulatorAverageCovariance(boolean fullCovariance)
fullCovariance
- enables calculation of covariance for each pair of
data values. With fullCovariance off, covariance is computed between
the first data value and all others.public AccumulatorAverageCovariance(long blockSize)
public AccumulatorAverageCovariance(long blockSize, boolean fullCovariance)
public boolean addData(IData data)
AccumulatorAverageFixed
addData
in class AccumulatorAverageFixed
data
- data to be added.protected void doBlockSum()
AccumulatorAverageFixed
doBlockSum
in class AccumulatorAverageFixed
public IData getData()
getData
in interface IDataSource
getData
in class AccumulatorAverageFixed
public void reset()
AccumulatorAverage
reset
in class AccumulatorAverageFixed
public IDataInfo processDataInfo(IDataInfo incomingDataInfo)
AccumulatorAverage
processDataInfo
in class AccumulatorAverageFixed
incomingDataInfo
- the DataInfo instance for the data that will be given to
addDatapublic static AccumulatorAverage.StatType[] statChoices()