public class IMDSBuilder
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
protected RingBuffer<ValueContainer> |
_realElementValues
Puffer, der die Zuordnung: Reale Elemente -> Werte enthält.
|
| Constructor and Description |
|---|
IMDSBuilder(boolean merge,
boolean noChangeMarkerPerCell,
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,
int startPeriodIndex)
Initialisierung.
|
| Modifier and Type | Method and Description |
|---|---|
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.
|
void |
throwAway()
Verwirft den zuletzt eingefügten Datensatz
|
protected RingBuffer<ValueContainer> _realElementValues
public IMDSBuilder(boolean merge,
boolean noChangeMarkerPerCell,
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,
int startPeriodIndex)
merge - true falls Datensätze verschmolzen werden sollen.noChangeMarkerPerCell - true wenn NoChange-Informationen für Zustandsprotokolle pro Zelle generiert werden sollen (statt pro Zeile)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.startPeriodIndex - 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 abgebrochenFailureException - 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()
public void throwAway()
throws java.lang.InterruptedException
java.lang.InterruptedException