public class Aggregator
extends java.lang.Object
Constructor and Description |
---|
Aggregator(ProcessingInformation pi) |
Modifier and Type | Method and Description |
---|---|
boolean |
aggregate(java.util.List<BaseDataSet> bds)
Führt die Aggregation durch.
|
IntermediateDataSet[] |
endOfInterval(byte status,
int currentPeriod)
Aggregationsdatensätze abrufen, die zum Ende eines Intervalls vorliegen.
|
IntermediateDataSet[] |
endOfProtocol(int currentPeriod)
Aggregationsdatensätze abrufen, die zum Ende der Protokollerstellung vorliegen.
|
int[] |
getLinkedAttributes()
Zeigt an welche Attribute durch die Aggregation
spalte zusammengefasst werden. |
boolean |
isListAggregation()
Werden auch nicht aggregierte Daten versendet?
|
public Aggregator(ProcessingInformation pi) throws de.bsvrz.sys.funclib.losb.exceptions.FailureException
pi
- Informationen für die Datenaufbereitung.de.bsvrz.sys.funclib.losb.exceptions.FailureException
- Fehler beim Anlegen von neuen Instanzen.public boolean aggregate(java.util.List<BaseDataSet> bds)
bds
- Listepublic IntermediateDataSet[] endOfInterval(byte status, int currentPeriod)
status
- Status der dem Ausgangsadtensatz zugewiesen wird.currentPeriod
- Aktueller Zeitbereich0
, und dem Ergebnis der Aggregation für Intervall_Spalte in 1
.
Die Einträge können null
sein, falls keine Aggregationsdaten vorliegen.public IntermediateDataSet[] endOfProtocol(int currentPeriod)
currentPeriod
- Aktueller Zeitbereich[0]
und denm Ergebnis der Aggregation für Gesamt_Spalte in [1]
.
Einträge können null
sein, falls keine Aggregationsdaten vorliegen.public boolean isListAggregation()
true
falls liste
eine der ausgewählten die Aggregationsanwendungen ist.public int[] getLinkedAttributes()
spalte
zusammengefasst werden. Zusammengehörige Spalten werden duch die gleichen Nummern
gekennzeichnet.null
falls die spalten
Aggregation nicht verwendet wird.