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()