Class BucketContainerIterator
java.lang.Object
de.bsvrz.ars.ars.persistence.iter.BucketContainerIterator
- All Implemented Interfaces:
DataIterator,java.lang.AutoCloseable
public class BucketContainerIterator extends java.lang.Object implements DataIterator
Iteriert wie der
SequentialContainerIterator über eine Menge von Containern. Diese Klasse muss benutzt werden, wenn sich die Containerdateien
zeitlich bzw. datenindexmäßig überschneiden.
In diesem Fall, werden die Container-Dateien in Buckets sortiert, wobei ein Bucket immer eine Menge an sich überschneidenden Containerdateien enthält. Die Buckets selbst werden aufsteigend nach Datenindex sortiert.
Diese Klasse erzeugt die Buckets nicht selbst, sondern sie werden im Konstruktor übergeben. Diese Klasse übernimmt dass iterieren und sortieren von den einzelnen Datensätzen.
-
Constructor Summary
Constructors Constructor Description BucketContainerIterator(ArchiveManager archiveManager, java.util.List<java.util.List<QueryDataSequence.IndexedContainer>> containerFiles, SyncKey<IdDataIdentification> indexLock, de.bsvrz.dav.daf.main.archive.ArchiveDataKind adk, DeletedTreatment deletedTreatment, de.bsvrz.dav.daf.main.archive.ArchiveOrder order, java.util.zip.Inflater inflater)Erstellt einen neuen BucketContainerIterator -
Method Summary
Modifier and Type Method Description voidclose()Terminiert das iterieren.ContainerManagementDatagetContainerManagementData()Gibt die Containerheaderdaten des Containers des aktuell betrachteten Datensatzes zurückbooleanisEmpty()Gibttruezurück, wenn der Iterator erschöpft ist.voidpeek(ContainerDataResult result)Kopiert die Daten des aktuellen Elements in das angegebene Result-Objekt.longpeekArchiveTime()Ruft die aktuelle Archivzeit ab.longpeekDataIndex()Ruft den aktuellen Datenindex ab.longpeekDataTime()Ruft die aktuelle Datenzeit ab.ContainerDataResultpeekNext()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.voidremove()Entfernt das aktuelle Element.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface de.bsvrz.ars.ars.persistence.iter.DataIterator
poll
-
Constructor Details
-
BucketContainerIterator
public BucketContainerIterator(ArchiveManager archiveManager, java.util.List<java.util.List<QueryDataSequence.IndexedContainer>> containerFiles, SyncKey<IdDataIdentification> indexLock, de.bsvrz.dav.daf.main.archive.ArchiveDataKind adk, DeletedTreatment deletedTreatment, de.bsvrz.dav.daf.main.archive.ArchiveOrder order, java.util.zip.Inflater inflater) throws PersistenceException, SynchronizationFailedExceptionErstellt einen neuen BucketContainerIterator- Parameters:
archiveManager- ArchivmanagercontainerFiles- Vorsortierte Container-Dateien. Eine Liste von Container-Dateien-Gruppen, die sich jeweils zeitlich überschneiden. Die äußere Liste ist nach Datenindex sortiert.indexLock- Datenidentifikationadk- ArchivdatenartdeletedTreatment- Behandlung von gelöschten Datenorder- Sortierunginflater- Komprimierung- Throws:
PersistenceExceptionSynchronizationFailedException
-
-
Method Details
-
peek
Description copied from interface:DataIteratorKopiert 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:
peekin interfaceDataIterator- Parameters:
result- Ziel-Element- Throws:
PersistenceException
-
peekNext
Description copied from interface:DataIteratorGibt 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:
peekNextin interfaceDataIterator- Returns:
- Ziel-Element oder null falls es keinen nächsten Datensatz gibt
-
peekDataIndex
public long peekDataIndex()Description copied from interface:DataIteratorRuft den aktuellen Datenindex ab. Entspricht
ist aber wahrscheinlich performanter.ContainerDataResult result = new ContainerDataResult() this.peek(result) return result.getDataIndex()- Specified by:
peekDataIndexin interfaceDataIterator- Returns:
- Datenindex des aktuellen Elements
-
peekDataTime
public long peekDataTime()Description copied from interface:DataIteratorRuft die aktuelle Datenzeit ab. Entspricht
ist aber wahrscheinlich performanter.ContainerDataResult result = new ContainerDataResult() this.peek(result) return result.getDataTime()- Specified by:
peekDataTimein interfaceDataIterator- Returns:
- Datenzeit des aktuellen Elements
-
peekArchiveTime
public long peekArchiveTime()Description copied from interface:DataIteratorRuft die aktuelle Archivzeit ab. Entspricht
ist aber wahrscheinlich performanter.ContainerDataResult result = new ContainerDataResult() this.peek(result) return result.getArchiveTime()- Specified by:
peekArchiveTimein interfaceDataIterator- Returns:
- Archivzeit des aktuellen Elements
-
remove
Description copied from interface:DataIteratorEntfernt das aktuelle Element.- Specified by:
removein interfaceDataIterator- Throws:
PersistenceExceptionSynchronizationFailedException
-
isEmpty
public boolean isEmpty()Description copied from interface:DataIteratorGibttruezurück, wenn der Iterator erschöpft ist. Ist das der Fall liefern alle anderen Funktionen außer close()NoSuchElementExceptions.- Specified by:
isEmptyin interfaceDataIterator- Returns:
true, wenn der Iterator erschöpft ist, sonstfalse
-
close
public void close()Description copied from interface:DataIteratorTerminiert das iterieren. Hierdurch werden alle ggf. noch offenen Containerdateien geschlossen.- Specified by:
closein interfacejava.lang.AutoCloseable- Specified by:
closein interfaceDataIterator
-
getContainerManagementData
Description copied from interface:DataIteratorGibt die Containerheaderdaten des Containers des aktuell betrachteten Datensatzes zurück- Specified by:
getContainerManagementDatain interfaceDataIterator- Returns:
- ContainerManagementData
- Throws:
PersistenceException- Lesefehler im Persistenzverzeichnis
-