de.bsvrz.pua.prot.processing
Class IMDSBuilder

java.lang.Object
  extended by de.bsvrz.pua.prot.processing.IMDSBuilder

public class IMDSBuilder
extends java.lang.Object

Erzeugt Ausgangsdatensätze und legt sie in einem Puffer ab.

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

Field Summary
protected  RingBuffer<ValueContainer> realElementValues
          Puffer, der die Zuordnung: Reale Elemente -> Werte enthält.
 
Constructor Summary
IMDSBuilder(boolean merge, java.util.List<Elements> attributes, Tuple<ExpressionTree,java.lang.Boolean> constraint, java.util.Hashtable<RealElement,ValueProvider> realElements, java.util.Hashtable<TempAttributeDescription,TempAttribut> tempElements, ProcessingBuffer processingBuffer, Status status)
          Initialisierung.
 
Method Summary
 void collectData(boolean insertEmpty, long winnerTimeStamp)
          Sammelt die Werte der realen Attribute.
 void createIntermediateDataSet(boolean done)
          Bereitet die Basisdaten auf und erstellt Ausgangsdatensätze.
 byte getStatus()
          Liefert den momentanen Status zurück.
 boolean isDone()
          Zeigt an dass keine weiteren Daten mehr vorliegen.
 void nextInterval(long endOfInterval)
          Markiert den zuletzt eingefügten Ausgangsdatensatz als den letzten des Intervalls.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

realElementValues

protected RingBuffer<ValueContainer> realElementValues
Puffer, der die Zuordnung: Reale Elemente -> Werte enthält.

Constructor Detail

IMDSBuilder

public IMDSBuilder(boolean merge,
                   java.util.List<Elements> attributes,
                   Tuple<ExpressionTree,java.lang.Boolean> constraint,
                   java.util.Hashtable<RealElement,ValueProvider> realElements,
                   java.util.Hashtable<TempAttributeDescription,TempAttribut> tempElements,
                   ProcessingBuffer processingBuffer,
                   Status status)
Initialisierung.

Parameters:
merge - true falls Datensätze verschmolzen werden sollen.
attributes - Im Spalten-Bereich definierte Attribute.
constraint - Im Skript definierte Einschränlung.
realElements - Zuordnung der realen Attribute zu ihren Wertebeschaffern.
tempElements - Zuordnung der temporären Attribute zu ihren Wertebeschaffern.
processingBuffer - Datenaufbereiter.
status - Objekt zur Statusberechung.
Method Detail

collectData

public void collectData(boolean insertEmpty,
                        long winnerTimeStamp)
Sammelt die Werte der realen Attribute. Stellt dann einen Basisdatensatz mit den Werten der realen Attribute zusammen.

Parameters:
insertEmpty - true legt fest, dass ein leerer Datensatz eingefügt werden soll.
winnerTimeStamp - Minimaler, nicht-aufgefüllter Zeitstempel.

createIntermediateDataSet

public void createIntermediateDataSet(boolean done)
                               throws java.lang.InterruptedException,
                                      FailureException
Bereitet die Basisdaten auf und erstellt Ausgangsdatensätze. Wertet alle im Puffer liegenden Wert aus.

Parameters:
done - Das Sammeln der Daten wurde abgeschlossen.
Throws:
java.lang.InterruptedException - Datenaufbereitung wurde abgebrochen
FailureException - Fehler beim Aufbereiten der Daten.

isDone

public boolean isDone()
Zeigt an dass keine weiteren Daten mehr vorliegen.

Returns:
true falls keine weiteren Daten mehr vorliegen.

nextInterval

public void nextInterval(long endOfInterval)
Markiert den zuletzt eingefügten Ausgangsdatensatz als den letzten des Intervalls.

Parameters:
endOfInterval - Endzeitpunkt des Intervalls, das gerade beendet wurde.
See Also:
ValueContainer.setLastOfInterval(long)

getStatus

public byte getStatus()
Liefert den momentanen Status zurück.

Returns:
Status zwischen 0 und 100.


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