Package ca.uhn.fhir.jpa.dao.expunge

Class PartitionRunner

java.lang.Object

ca.uhn.fhir.jpa.dao.expunge.PartitionRunner

public class PartitionRunner
extends Object

Constructor Summary

Constructors

Constructor	Description
PartitionRunner(String theProcessName, String theThreadPrefix, int theBatchSize, int theThreadCount)	Constructor - Use this constructor if you do not want any transaction management
PartitionRunner(String theProcessName, String theThreadPrefix, int theBatchSize, int theThreadCount, HapiTransactionService theTransactionService, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)	Constructor - Use this constructor and provide a RequestDetails and HapiTransactionService if you want each individual callable task to be performed in a managed transaction.

Method Summary

Modifier and Type	Method	Description
void	runInPartitionedThreads(List<ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId> theResourceIds, Consumer<List<ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId>> partitionConsumer)

Methods inherited from class java.lang.Object

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

Constructor Details

PartitionRunner

public PartitionRunner(String theProcessName,
 String theThreadPrefix,
 int theBatchSize,
 int theThreadCount)

Constructor - Use this constructor if you do not want any transaction management

PartitionRunner

public PartitionRunner(String theProcessName,
 String theThreadPrefix,
 int theBatchSize,
 int theThreadCount,
 @Nullable
 HapiTransactionService theTransactionService,
 @Nullable
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

Constructor - Use this constructor and provide a RequestDetails and HapiTransactionService if you want each individual callable task to be performed in a managed transaction.

Method Details

runInPartitionedThreads

public void runInPartitionedThreads(List<ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId> theResourceIds,
 Consumer<List<ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId>> partitionConsumer)