Class BulkSelectQueryParallelProcessor
- java.lang.Object
-
- fr.gouv.vitam.worker.core.plugin.bulkatomicupdate.BulkSelectQueryParallelProcessor
-
- All Implemented Interfaces:
java.lang.AutoCloseable
public class BulkSelectQueryParallelProcessor extends java.lang.Object implements java.lang.AutoCloseable
Handles execution of bulk select queries This class is stateful, and supports concurrent access to public methods.
-
-
Constructor Summary
Constructors Constructor Description BulkSelectQueryParallelProcessor(java.lang.String pluginName, java.lang.String processId, int tenantId, MetaDataClient metadataClient, BatchReportClient batchReportClient, InternalActionKeysRetriever internalActionKeysRetriever, AccessContractModel accessContractModel, JsonLineWriter jsonLineWriter)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
int
getNbOKs()
int
getNbWarnings()
void
processBulkQueries(java.util.List<CountingIterator.EntryWithIndex<com.fasterxml.jackson.databind.JsonNode>> bulkQueriesToProcess)
-
-
-
Constructor Detail
-
BulkSelectQueryParallelProcessor
public BulkSelectQueryParallelProcessor(java.lang.String pluginName, java.lang.String processId, int tenantId, MetaDataClient metadataClient, BatchReportClient batchReportClient, InternalActionKeysRetriever internalActionKeysRetriever, AccessContractModel accessContractModel, JsonLineWriter jsonLineWriter)
-
-
Method Detail
-
processBulkQueries
public void processBulkQueries(java.util.List<CountingIterator.EntryWithIndex<com.fasterxml.jackson.databind.JsonNode>> bulkQueriesToProcess) throws MetaDataExecutionException, MetaDataDocumentSizeException, InvalidParseOperationException, MetaDataClientServerException, InvalidCreateOperationException, java.io.IOException, VitamClientInternalException
-
getNbWarnings
public int getNbWarnings()
-
getNbOKs
public int getNbOKs()
-
close
public void close() throws java.io.IOException, VitamClientInternalException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Throws:
java.io.IOException
VitamClientInternalException
-
-