de.bsvrz.pua.prot.processing.archivebuffer
Class Aggregator

java.lang.Object
  extended by de.bsvrz.pua.prot.processing.archivebuffer.Aggregator

public class Aggregator
extends java.lang.Object

Führt das Aggregieren von Daten durch. Spalten-Aggregation: Ein Aggregationsergebnis für alle Attribute, die sich nur im verwendeten Objekt unterscheiden. D.h. mehreren Attributen wird das gleiche Aggregationsobjekt zugeordnet. Objekt-Aggregation: Ein Aggregationsergebnis pro Attribut. Jedem einzelnen Attribut wird ein eigenes Aggregationsobjekt zugeordnet.

Version:
$Revision: 1.2 $ / $Date: 2008/01/22 16:55:49 $ / ($Author: yvonnes $)
Author:
beck et al. projects GmbH, Martin Hilgers

Constructor Summary
Aggregator(ProcessingInformation pi)
           
 
Method Summary
 boolean aggregate(BaseDataSet[] bds)
          Führt die Aggregation durch.
 IntermediateDataSet[] endOfInterval(byte status)
          Aggregationsdatensätze abrufen, die zum Ende eines Intervalls vorliegen.
 IntermediateDataSet[] endOfProtocol()
          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?
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Aggregator

public Aggregator(ProcessingInformation pi)
           throws FailureException
Parameters:
pi - Informationen für die Datenaufbereitung.
Throws:
FailureException - Fehler beim Anlegen von neuen Instanzen.
Method Detail

aggregate

public boolean aggregate(BaseDataSet[] bds)
Führt die Aggregation durch. Wird für jeden Ausgangsdatensatz einmal aufgreufen.

Parameters:
bds -
Returns:
Falls der Ausgangsdatensatz an den Auftraggeber weitergeleitet werden soll. Dies ist der Fall, wenn die Anwendung "liste" verwendet wurde.

endOfInterval

public IntermediateDataSet[] endOfInterval(byte status)
Aggregationsdatensätze abrufen, die zum Ende eines Intervalls vorliegen. Muss aufgerufen werden, bevor die Aggregation für ein weiteres Intervall beginnt.

Parameters:
status - Status der dem Ausgangsadtensatz zugewiesen wird.
Returns:
Feld mit Ergebnis der Aggregation für Intervall_Objekt in 0, und dem Ergebnis der Aggregation für Intervall_Spalte inf 1. Die Einträge können null sein, falls keine Aggregationsdaten vorliegen.

endOfProtocol

public IntermediateDataSet[] endOfProtocol()
Aggregationsdatensätze abrufen, die zum Ende der Protokollerstellung vorliegen.

Returns:
Feld mit dem Ergebnis der Aggregation für Gesamt_Objekt in [0] und denm Ergebnis der Aggregation für Gesamt_Spalte in [1]. Einträge können null sein, falls keine Aggregationsdaten vorliegen.

isListAggregation

public boolean isListAggregation()
Werden auch nicht aggregierte Daten versendet?

Returns:
true falls liste eine der ausgewählten die Aggregationsanwendungen ist.

getLinkedAttributes

public int[] getLinkedAttributes()
Zeigt an welche Attribute durch die Aggregation spalte zusammengefasst werden. Zusammengehörige Spalten werden duch die gleichen Nummern gekennzeichnet.

Returns:
Zusammen gehörende Spalten. null falls die spalten Aggregation nicht verwendet wird.


Copyright © 2005-2008 beck et al. projects GmbH All Rights Reserved.