DataPipe, DataPipeForked, IDataSink, IDataSourcepublic class AccumulatorAverageBlocklessSlim extends DataAccumulator
This accumulator accepts any type of Data
| Modifier and Type | Class | Description |
|---|---|---|
static class |
AccumulatorAverageBlocklessSlim.StatType |
Enumerated type that can be used to indicated the statistic to be taken
from the accumulator (e.g., average, error, current value, etc.).
|
| Modifier and Type | Field | Description |
|---|---|---|
static AccumulatorAverageBlocklessSlim.StatType |
AVERAGE |
|
protected long |
count |
|
protected IDataInfo |
inDataInfo |
|
protected static IFunction |
negativeChop |
|
static AccumulatorAverageBlocklessSlim.StatType |
STANDARD_DEVIATION |
|
protected IData |
sum |
|
protected IData |
sumSquare |
|
protected IData |
work |
active, hasUnpushedData, pushInterval, putCountdataInfo, dataSink, tag| Constructor | Description |
|---|---|
AccumulatorAverageBlocklessSlim() |
| Modifier and Type | Method | Description |
|---|---|---|
boolean |
addData(IData data) |
Add the given values to the sums and block sums.
|
IData |
getData() |
Returns a DataGroup with Data instances holding the statistics kept by
this accumulator (as described in general comments for this class).
|
AccumulatorAverageBlockless.AllData |
getRawData() |
|
long |
getSampleCount() |
|
protected IDataInfo |
processDataInfo(IDataInfo inputDataInfo) |
Informs this DataProcessor of the DataInfo for the Data it will be
processing.
|
void |
putDataInfo(IDataInfo inputDataInfo) |
Prepares the accumulator for input data.
|
void |
reset() |
Resets all sums to zero.
|
void |
setRawData(AccumulatorAverageBlockless.AllData ad) |
|
static AccumulatorAverageBlocklessSlim.StatType[] |
statChoices() |
getPushInterval, isActive, processData, setActive, setPushInterval, toStringgetDataInfo, getTag, putDataaddDataSink, getDataSink, getDataSinks, removeDataSink, setDataSink, setDataSinksgetDataInfo, getTagpublic static final AccumulatorAverageBlocklessSlim.StatType AVERAGE
public static final AccumulatorAverageBlocklessSlim.StatType STANDARD_DEVIATION
protected IDataInfo inDataInfo
protected long count
protected IData sum
protected IData sumSquare
protected IData work
protected static final IFunction negativeChop
public boolean addData(IData data)
addData in class DataAccumulatordata - the data to be processedpublic IData getData()
getData in interface IDataSourcegetData in class DataAccumulatorpublic void reset()
reset in class DataAccumulatorpublic void putDataInfo(IDataInfo inputDataInfo)
putDataInfo in interface IDataSinkputDataInfo in class DataProcessorinputDataInfo - the DataInfo instance for the data that will be given to
addDataprotected IDataInfo processDataInfo(IDataInfo inputDataInfo)
DataProcessorprocessDataInfo in class DataProcessorinputDataInfo - the DataInfo of the Data that will be input to this
DataProcessorpublic long getSampleCount()
public static AccumulatorAverageBlocklessSlim.StatType[] statChoices()
public AccumulatorAverageBlockless.AllData getRawData()
public void setRawData(AccumulatorAverageBlockless.AllData ad)