Package fr.gouv.vitam.storage.engine.client

Class StorageClientOfferLogIterator

java.lang.Object

fr.gouv.vitam.common.iterables.BulkBufferingEntryIterator<OfferLog>

fr.gouv.vitam.storage.engine.client.StorageClientOfferLogIterator

All Implemented Interfaces:

java.util.Iterator<OfferLog>

public class StorageClientOfferLogIterator
extends BulkBufferingEntryIterator<OfferLog>

Implementation of TraceabilityIterator for Storage. Iterate over OfferLog for the traceability

Constructor Summary

Constructors

Constructor	Description
StorageClientOfferLogIterator(StorageClientFactory storageClientFactory, java.lang.String strategyId, java.lang.String offerId, Order order, DataCategory dataCategory, int chunkSize, java.lang.Long startOffset)

Method Summary

Modifier and Type	Method	Description
protected java.util.List<OfferLog>	loadNextChunk(int chunkSize)	Loads a chunk of the specified size.

Methods inherited from class fr.gouv.vitam.common.iterables.BulkBufferingEntryIterator

hasNext, next

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

StorageClientOfferLogIterator

public StorageClientOfferLogIterator(StorageClientFactory storageClientFactory,
                                     java.lang.String strategyId,
                                     java.lang.String offerId,
                                     Order order,
                                     DataCategory dataCategory,
                                     int chunkSize,
                                     java.lang.Long startOffset)

Method Detail

loadNextChunk

protected java.util.List<OfferLog> loadNextChunk(int chunkSize)

Description copied from class: BulkBufferingEntryIterator

Loads a chunk of the specified size.

Specified by:

loadNextChunk in class BulkBufferingEntryIterator<OfferLog>

Returns:

List with next entries to process. Returned list must be the size specified, unless end of data is reached.