public class RealtimeArchiveFiller extends Object
| Modifier and Type | Field and Description |
|---|---|
protected long |
collectionSegmentStart |
protected ParameterGroupIdDb |
parameterGroupIdMap |
protected ParameterIdDb |
parameterIdMap |
protected TreeMap<Long,Map<Integer,PGSegment>> |
pgSegments |
| Constructor and Description |
|---|
RealtimeArchiveFiller(ParameterArchive parameterArchive,
Map<String,Object> config) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
consolidateAndWriteToArchive(Collection<PGSegment> pgList)
writes data into the archive
|
void |
flush() |
long |
getNumProcessedParameters() |
protected long |
processParameters(List<ParameterValue> items)
adds the parameters to the pgSegments structure and return the highest timestamp or -1 if all parameters have been ignored (because they were too old)
parameters older than ignoreOlderThan are ignored.
|
void |
updateItems(int subscriptionId,
List<ParameterValue> items) |
protected final ParameterIdDb parameterIdMap
protected final ParameterGroupIdDb parameterGroupIdMap
protected long collectionSegmentStart
public RealtimeArchiveFiller(ParameterArchive parameterArchive, Map<String,Object> config)
public void updateItems(int subscriptionId,
List<ParameterValue> items)
updateItems in interface ParameterConsumerpublic void flush()
protected long processParameters(List<ParameterValue> items)
items - protected void consolidateAndWriteToArchive(Collection<PGSegment> pgList)
pgList - public long getNumProcessedParameters()
Copyright © 2018 Space Applications Services. All rights reserved.