Package fr.gouv.vitam.metadata.common.bulkatomicupdate

Class BulkSelectQueryParallelProcessor

java.lang.Object

fr.gouv.vitam.metadata.common.bulkatomicupdate.BulkSelectQueryParallelProcessor

public class BulkSelectQueryParallelProcessor
extends Object

Handles execution of bulk select queries, in concurrent executors This class is stateful, and supports concurrent access to public methods.

Constructor Summary

Constructors

Constructor	Description
BulkSelectQueryParallelProcessor(MetaDataClient metadataClient, InternalActionKeysRetriever internalActionKeysRetriever, int threadPoolSize, int threadPoolQueueSize, int batchSize, Consumer<BulkSelectQueryResultOK> successReporter, Consumer<BulkSelectQueryResultFailure> failureReporter, QueryRestrictionConverter queryRestrictionConverter, boolean allowInternalFieldsUpdate)

Method Summary

Modifier and Type	Method	Description
int	getNbOKs()
int	getNbWarnings()
void	processQueries(Iterator<com.fasterxml.jackson.databind.JsonNode> queryIterator)

Methods inherited from class java.lang.Object

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

Constructor Details

BulkSelectQueryParallelProcessor

public BulkSelectQueryParallelProcessor(MetaDataClient metadataClient,
 InternalActionKeysRetriever internalActionKeysRetriever,
 int threadPoolSize,
 int threadPoolQueueSize,
 int batchSize,
 Consumer<BulkSelectQueryResultOK> successReporter,
 Consumer<BulkSelectQueryResultFailure> failureReporter,
 QueryRestrictionConverter queryRestrictionConverter,
 boolean allowInternalFieldsUpdate)

Method Details

processQueries

public void processQueries(Iterator<com.fasterxml.jackson.databind.JsonNode> queryIterator)
                    throws InvalidParseOperationException

Throws:

InvalidParseOperationException

getNbWarnings

public int getNbWarnings()

getNbOKs

public int getNbOKs()