DataPipe, DataPipeForked, IDataSink, IDataSourcepublic class AccumulatorCounter extends DataAccumulator
addData method is invoked. Output is a DataDouble.| Modifier and Type | Field | Description |
|---|---|---|
protected DataDouble |
data |
active, hasUnpushedData, pushInterval, putCountdataInfo, dataSink, tag| Constructor | Description |
|---|---|
AccumulatorCounter() |
| Modifier and Type | Method | Description |
|---|---|---|
protected boolean |
addData(IData dummyData) |
Increments the counter.
|
IData |
getData() |
Returns the DataInteger with the count.
|
IDataInfo |
processDataInfo(IDataInfo incomingDataInfo) |
Does nothing.
|
void |
reset() |
Sets count to zero.
|
getPushInterval, isActive, processData, setActive, setPushInterval, toStringgetDataInfo, getTag, putData, putDataInfoaddDataSink, getDataSink, getDataSinks, removeDataSink, setDataSink, setDataSinksputData, putDataInfogetDataInfo, getTagprotected final DataDouble data
public IDataInfo processDataInfo(IDataInfo incomingDataInfo)
processDataInfo in class DataProcessorincomingDataInfo - the DataInfo of the Data that will be input to this
DataProcessorprotected boolean addData(IData dummyData)
addData in class DataAccumulatordummyData - the data to be processedpublic IData getData()
getData in interface IDataSourcegetData in class DataAccumulatorpublic void reset()
reset in class DataAccumulator