|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectde.bsvrz.pua.prot.processing.IMDSBuilder
public class IMDSBuilder
Erzeugt Ausgangsdatensätze und legt sie in einem Puffer ab.
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 |
---|
protected RingBuffer<ValueContainer> realElementValues
Constructor Detail |
---|
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)
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 |
---|
public void collectData(boolean insertEmpty, long winnerTimeStamp)
insertEmpty
- true
legt fest, dass ein leerer Datensatz eingefügt werden soll.winnerTimeStamp
- Minimaler, nicht-aufgefüllter Zeitstempel.public void createIntermediateDataSet(boolean done) throws java.lang.InterruptedException, FailureException
done
- Das Sammeln der Daten wurde abgeschlossen.
java.lang.InterruptedException
- Datenaufbereitung wurde abgebrochen
FailureException
- Fehler beim Aufbereiten der Daten.public boolean isDone()
true
falls keine weiteren Daten mehr vorliegen.public void nextInterval(long endOfInterval)
endOfInterval
- Endzeitpunkt des Intervalls, das gerade beendet wurde.ValueContainer.setLastOfInterval(long)
public byte getStatus()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |