Package fr.gouv.vitam.worker.core.plugin.bulkatomicupdate

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

Modifier and Type	Method	Description
void	close()
int	getNbOKs()
int	getNbWarnings()
void	processBulkQueries(java.util.List<CountingIterator.EntryWithIndex<com.fasterxml.jackson.databind.JsonNode>> bulkQueriesToProcess)

Methods inherited from class java.lang.Object

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

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

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 interface java.lang.AutoCloseable

Throws:

java.io.IOException

VitamClientInternalException