SBArchivAnfrageBearbeiter
public class AggregatorVerwaltung extends java.lang.Object implements SBArchivAnfrageBearbeiter
Modifier and Type | Class | Description |
---|---|---|
protected class |
AggregatorVerwaltung.FSWrapper |
Erwitert ein Fahrstreifen mit Information ueber den Anzahl der gekommenen
Datensaetzen im letzten Zeitintervall.
|
protected class |
AggregatorVerwaltung.LZZWrapper |
Erweitert den LZZ SystemObjekt um die Menge der assoziierten FS.
|
Constructor | Description |
---|---|
AggregatorVerwaltung() |
Standard Konstruktor.
|
Modifier and Type | Method | Description |
---|---|---|
void |
addAggregator(AbstraktAggregator aggreg) |
Fuegt ein Aggregator in die Liste der verwalteten Agg. ein.
|
void |
bearbeiteArchivDaten(de.bsvrz.dav.daf.main.config.SystemObject objekt,
de.bsvrz.dav.daf.main.DataDescription datenBeschreibung,
de.bsvrz.dav.daf.main.DataState status,
de.bsvrz.dav.daf.main.Data daten,
long zeitStempel) |
Diese Methode soll die daten die aus dem Archiv kommen bearbeiten.
|
void |
berechneLangZeitdaten(AggregatorVerwaltung.LZZWrapper lzz,
long zeitStempelVon,
long zeitStempelBis) |
Berechnet die LangZeitDaten, triggert alle Agregatoren.
|
long |
getAnzahlDatenSaetzeLZZ(de.bsvrz.dav.daf.main.config.SystemObject fs) |
Erfragt dem Anzahl der eingekomenen DS fuer die LZZ, die das Fahrstreifen
fs enthaelt.
|
void |
initialisiere(de.bsvrz.dav.daf.main.ClientDavInterface connection,
long zeitPunktJetzt) |
Init, erzeutgt die Liste der LZZ liest die letzten DS aus dem Archiv aus
und nach dem synchronisiert die Aggregatoren, damit der letzte erzeugte
DatenSatz aus dem selben zeitIntervall ist.
|
void |
printAnzahlDatenSaetzeLZZ() |
Schreibt die Anzahl aller DS fuer alle LZZ aus.
|
void |
setZeitStempelGefunden(boolean zeitStempelGefunden) |
Setzt die Variable ein, wird als Wrapper aus Zugriffsgruenden in
unbenannten Kinder-Klassen benutzt.
|
void |
trigger() |
Startet die Aggregation, wird am ende des Abrufes gerufen.
|
void |
update(de.bsvrz.dav.daf.main.ResultData resultData) |
Wird beim jedem eingekommenen LZD Datensatz gerufen.
|
public void addAggregator(AbstraktAggregator aggreg)
aggreg
- Eine konkrete Implementations des Aggregatorspublic void initialisiere(de.bsvrz.dav.daf.main.ClientDavInterface connection, long zeitPunktJetzt)
connection
- Verbindung zum DAVzeitPunktJetzt
- Aktueller Zeitpunktpublic void update(de.bsvrz.dav.daf.main.ResultData resultData)
resultData
- ein empfangener Datensatzpublic long getAnzahlDatenSaetzeLZZ(de.bsvrz.dav.daf.main.config.SystemObject fs)
fs
- Fahrstreifenpublic void printAnzahlDatenSaetzeLZZ()
public void trigger()
public void berechneLangZeitdaten(AggregatorVerwaltung.LZZWrapper lzz, long zeitStempelVon, long zeitStempelBis)
lzz
- LZZ fuer die die Daten erzeugt werden sollenzeitStempelVon
- Beginn ZeitStempel des ZeitIntervalls fuer dem die Daten
erzeugt werden sollenzeitStempelBis
- Ende ZeitStempel des ZeitIntervalls fuer dem die Daten erzeugt
werden sollenpublic void bearbeiteArchivDaten(de.bsvrz.dav.daf.main.config.SystemObject objekt, de.bsvrz.dav.daf.main.DataDescription datenBeschreibung, de.bsvrz.dav.daf.main.DataState status, de.bsvrz.dav.daf.main.Data daten, long zeitStempel)
SBArchivAnfrageBearbeiter
bearbeiteArchivDaten
in interface SBArchivAnfrageBearbeiter
objekt
- Das objekt, dass die Daten geliefert hatdatenBeschreibung
- Beschreibung der Datenstatus
- Typ der Datendaten
- Der DatensatzzeitStempel
- Zeitstempel des datensatzespublic void setZeitStempelGefunden(boolean zeitStempelGefunden)
zeitStempelGefunden
- true, wenn ein Zeitstepel im Archiv gefunden ist