Class PrepareBulkAtomicUpdate

java.lang.Object
fr.gouv.vitam.worker.core.handler.ActionHandler
fr.gouv.vitam.worker.core.plugin.bulkatomicupdate.PrepareBulkAtomicUpdate
All Implemented Interfaces:
VitamAutoCloseable, AutoCloseable

public class PrepareBulkAtomicUpdate extends ActionHandler
Prepares the execution of atomic update queries. Queries are executed in bulks, each bulk is run concurrently is a thread pool. Queries are updated with access contract restrictions. Query projection is set to "_id" field only. Queries with internal fields are blocked ==> Report WARNING in batch report Queries result size is limited to 2. - If a single entry is found ==> Happy path, we append unitId to distribution file - No entries found ==> Report WARNING in batch report (no unit found) - 2 entries found ==> Report WARNING in batch report (multiple units found) Report entries are buffered and sent as bulks to BatchReport (to reduce IOs to BatchReport) Distribution file entries are buffered and written to disk in bulks (to reduce IO contention)