Package mocka.persistence
Class BulkPersistenceManager
java.lang.Object
mocka.persistence.BulkPersistenceManager
-
Constructor Summary
ConstructorsConstructorDescriptionBulkPersistenceManager(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor bulkProducerExecutor, org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor bulkConsumerExecutor, JdbcBatchWriter jdbcBatchWriter) -
Method Summary
Modifier and TypeMethodDescription<T> voidstart(EntityGenerator<T> generator, long totalCount, int batchSize, Class<T> entityType)
-
Constructor Details
-
BulkPersistenceManager
public BulkPersistenceManager(org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor bulkProducerExecutor, org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor bulkConsumerExecutor, JdbcBatchWriter jdbcBatchWriter)
-
-
Method Details
-
start
public <T> void start(EntityGenerator<T> generator, long totalCount, int batchSize, Class<T> entityType) throws InterruptedException - Throws:
InterruptedException
-