public class AggregationsPufferMenge extends Object
| Modifier and Type | Field and Description |
|---|---|
private de.bsvrz.dav.daf.main.ClientDavInterface |
_dav |
private static de.bsvrz.sys.funclib.debug.Debug |
_debug |
private long |
_erfassungsIntervall |
private de.bsvrz.dav.daf.main.config.SystemObject |
_obj |
private NavigableMap<Long,AbstraktAggregationsPuffer> |
pufferMenge
Menge aller Puffer mit Aggregationsdaten (indiziert nach Erfassungsintervall (Millisekunden)).
|
| Constructor and Description |
|---|
AggregationsPufferMenge(de.bsvrz.dav.daf.main.ClientDavInterface dav,
de.bsvrz.dav.daf.main.config.SystemObject obj)
Standardkonstruktor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
aktualisiere(AggregationsDatum datum,
boolean isAnalyse)
Aktualisiert diese Menge von Aggregationspuffern mit neuen Daten.
|
Collection<AggregationsDatum> |
getDatenFuerZeitraum(long begin,
long ende,
AggregationsIntervall aggregationsIntervall)
Erfragt alle in dieser Puffermenge gespeicherten Datensaetze eines
Unterpuffers, deren Zeitstempel im Intervall [begin, ende[ liegen und
deren Erfassungs- bzw.
|
AbstraktAggregationsPuffer |
getPuffer(AggregationsIntervall intervall)
Erfragt den Datenpuffer fuer Daten des uebergebenen
Aggregationsintervalls.
|
protected void |
updatePuffer(long erfassungsIntervall)
Aktualisiert die Puffer zur Speicherung der aggregierten Daten wenn sich das Erfassungsintervall ändert.
|
private final NavigableMap<Long,AbstraktAggregationsPuffer> pufferMenge
private final de.bsvrz.dav.daf.main.ClientDavInterface _dav
private final de.bsvrz.dav.daf.main.config.SystemObject _obj
private long _erfassungsIntervall
private static final de.bsvrz.sys.funclib.debug.Debug _debug
public AggregationsPufferMenge(de.bsvrz.dav.daf.main.ClientDavInterface dav,
de.bsvrz.dav.daf.main.config.SystemObject obj)
dav - Verbindung zum Datenverteilerobj - Systemobjekt, das gepuffert wirdprotected void updatePuffer(long erfassungsIntervall)
erfassungsIntervall - Neues Erfassungsintervallpublic void aktualisiere(AggregationsDatum datum, boolean isAnalyse)
datum - Zu aggregierendes DatumisAnalyse - Handelt es sich um einen Analysewert (Eingangsdatum), falls ja wird ggf. das Erfassungsintervall und
die zu berechnenden Aggregationsstufen aktualisiert.public final Collection<AggregationsDatum> getDatenFuerZeitraum(long begin, long ende, AggregationsIntervall aggregationsIntervall)
begin - Begin des Intervallsende - Ende des IntervallsaggregationsIntervall - das Intervall, fuer dessen Aggregation Daten gesucht werdenpublic final AbstraktAggregationsPuffer getPuffer(AggregationsIntervall intervall)
intervall - ein Aggregationsintervall (null erfragt den
Datenpuffer fuer messwertersetzte Fahrstreifendaten)Copyright © 2016 BitCtrl Systems GmbH. All rights reserved.