Class SequentialContainerIterator
java.lang.Object
de.bsvrz.ars.ars.persistence.iter.SequentialContainerIterator
- All Implemented Interfaces:
DataIterator
,AutoCloseable
Iteration über die Daten von einer Liste von Containern. Die Container müssen bereits nach Datenindex nicht überlappend aufsteigend sortiert sein.
Ist das nicht der Fall (z.B. bei nachgeforderten Daten), sollte ein BucketContainerIterator
benutzt werden.
-
Constructor Summary
ConstructorsConstructorDescriptionSequentialContainerIterator
(List<QueryDataSequence.IndexedContainer> containerFiles, de.bsvrz.dav.daf.main.archive.ArchiveDataKind adk, QueryDataSequence.IndexedContainer nextContainer, IdDataIdentification idDataIdentification, DataGapManager gapManager) Erstellt einen neuen SequentialContainerIterator -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
Terminiert das iterieren.Gibt die Containerheaderdaten des Containers des aktuell betrachteten Datensatzes zurückboolean
isEmpty()
Gibttrue
zurück, wenn der Iterator erschöpft ist.void
peek
(ContainerDataResult result) Kopiert die Daten des aktuellen Elements in das angegebene Result-Objekt.long
Ruft die aktuelle Archivzeit ab.long
Ruft den aktuellen Datenindex ab.long
Ruft die aktuelle Datenzeit ab.peekNext()
Gibt Daten des auf die gültige Sequenz folgenden Datensatzes zurück, damit kann dann unter anderem bestimmt werden, wie lange der Datensatz gültig ist.void
remove()
Entfernt/Überspringt das aktuelle Element.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface de.bsvrz.ars.ars.persistence.iter.DataIterator
poll
-
Constructor Details
-
SequentialContainerIterator
public SequentialContainerIterator(List<QueryDataSequence.IndexedContainer> containerFiles, de.bsvrz.dav.daf.main.archive.ArchiveDataKind adk, @Nullable QueryDataSequence.IndexedContainer nextContainer, IdDataIdentification idDataIdentification, DataGapManager gapManager) throws PersistenceException Erstellt einen neuen SequentialContainerIterator- Parameters:
containerFiles
- Containerdateien, bereits sortiertadk
- ArchivdatenartnextContainer
- Den Containerdateien folgender ContaineridDataIdentification
- DatenidentifikationgapManager
- Verwaltung von Datenlücken- Throws:
PersistenceException
- Lesefehler im Persistenzverzeichnis
-
-
Method Details
-
peek
Description copied from interface:DataIterator
Kopiert die Daten des aktuellen Elements in das angegebene Result-Objekt. Dies ist eine Optimierung, damit nicht ständig neue Result-Objekt angelegt werden müssen.- Specified by:
peek
in interfaceDataIterator
- Parameters:
result
- Ziel-Element- Throws:
PersistenceException
- Lesefehler im Persistenzverzeichnis
-
peekNext
Description copied from interface:DataIterator
Gibt Daten des auf die gültige Sequenz folgenden Datensatzes zurück, damit kann dann unter anderem bestimmt werden, wie lange der Datensatz gültig ist. Diese Methode darf nur aufgerufen werden, wennDataIterator.isEmpty()
true zurückliefert.- Specified by:
peekNext
in interfaceDataIterator
- Returns:
- Ziel-Element oder null, falls es keinen nächsten Datensatz gibt
- Throws:
PersistenceException
- Lesefehler im PersistenzverzeichnisSynchronizationFailedException
- Synchronisierung fehlgeschlagen
-
peekDataIndex
public long peekDataIndex()Description copied from interface:DataIterator
Ruft den aktuellen Datenindex ab. Entspricht
ist aber wahrscheinlich performanter.ContainerDataResult result = new ContainerDataResult() this.peek(result) return result.getDataIndex()
- Specified by:
peekDataIndex
in interfaceDataIterator
- Returns:
- Datenindex des aktuellen Elements
-
peekDataTime
public long peekDataTime()Description copied from interface:DataIterator
Ruft die aktuelle Datenzeit ab. Entspricht
ist aber wahrscheinlich performanter.ContainerDataResult result = new ContainerDataResult() this.peek(result) return result.getDataTime()
- Specified by:
peekDataTime
in interfaceDataIterator
- Returns:
- Datenzeit des aktuellen Elements
-
peekArchiveTime
public long peekArchiveTime()Description copied from interface:DataIterator
Ruft die aktuelle Archivzeit ab. Entspricht
ist aber wahrscheinlich performanter.ContainerDataResult result = new ContainerDataResult() this.peek(result) return result.getArchiveTime()
- Specified by:
peekArchiveTime
in interfaceDataIterator
- Returns:
- Archivzeit des aktuellen Elements
-
remove
Description copied from interface:DataIterator
Entfernt/Überspringt das aktuelle Element. Der Container wird nicht modifiziert, nur der Iterator.- Specified by:
remove
in interfaceDataIterator
- Throws:
PersistenceException
- Lesefehler im PersistenzverzeichnisSynchronizationFailedException
- Synchronisierung fehlgeschlagen
-
isEmpty
public boolean isEmpty()Description copied from interface:DataIterator
Gibttrue
zurück, wenn der Iterator erschöpft ist. Ist das der Fall liefern alle anderen Funktionen außer close()NoSuchElementException
s.- Specified by:
isEmpty
in interfaceDataIterator
- Returns:
true
, wenn der Iterator erschöpft ist, sonstfalse
-
close
public void close()Description copied from interface:DataIterator
Terminiert das iterieren. Hierdurch werden alle ggf. noch offenen Containerdateien geschlossen.- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceDataIterator
-
getContainerManagementData
Description copied from interface:DataIterator
Gibt die Containerheaderdaten des Containers des aktuell betrachteten Datensatzes zurück- Specified by:
getContainerManagementData
in interfaceDataIterator
- Returns:
- ContainerManagementData
- Throws:
PersistenceException
- Lesefehler im Persistenzverzeichnis
-