public class AggregatorVerwaltung extends Object implements SBArchivAnfrageBearbeiter
Modifier and Type | Class and 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 and Description |
---|
AggregatorVerwaltung()
Standard Konstruktor.
|
Modifier and Type | Method and 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 istCopyright © 2017 BitCtrl Systems GmbH. All rights reserved.