Package uk.ac.ebi.utils.threading.batchproc.processors

Class SetBasedBatchProcessor<E,BJ extends Consumer<Set<E>>>

java.lang.Object

uk.ac.ebi.utils.threading.batchproc.BatchProcessor<B,BC,BJ>

uk.ac.ebi.utils.threading.batchproc.ItemizedBatchProcessor<E,B,BC,BJ>

uk.ac.ebi.utils.threading.batchproc.processors.CollectionBasedBatchProcessor<E,Set<E>,SetBatchCollector<E>,BJ>

uk.ac.ebi.utils.threading.batchproc.processors.SetBasedBatchProcessor<E,BJ>

@Deprecated
public abstract class SetBasedBatchProcessor<E,BJ extends Consumer<Set<E>>>
extends CollectionBasedBatchProcessor<E,Set<E>,SetBatchCollector<E>,BJ>

Deprecated.

the functionality available in this package is provided by project Reactor and we recommend to switch to that. @see ReactorUtils

Field Summary

Fields inherited from class uk.ac.ebi.utils.threading.batchproc.BatchProcessor

jobLogPeriod, log

Constructor Summary

Constructors

Constructor	Description
SetBasedBatchProcessor()	Deprecated.
SetBasedBatchProcessor(int maxBatchSize)	Deprecated.
SetBasedBatchProcessor(BJ batchJob, int maxBatchSize)	Deprecated.
SetBasedBatchProcessor(BJ batchJob, Supplier<Set<E>> batchFactory, int maxBatchSize)	Deprecated.

Method Summary

Methods inherited from class uk.ac.ebi.utils.threading.batchproc.processors.CollectionBasedBatchProcessor

setMaxBatchSize

Methods inherited from class uk.ac.ebi.utils.threading.batchproc.ItemizedBatchProcessor

process, process, process, process, process, process

Methods inherited from class uk.ac.ebi.utils.threading.batchproc.BatchProcessor

getBatchCollector, getBatchJob, getCompletedBatches, getExecutor, getSubmittedBatches, handleNewBatch, handleNewBatch, setBatchCollector, setBatchJob, setExecutor, setJobLogPeriod, waitExecutor, wrapBatchJob

Methods inherited from class java.lang.Object

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

Constructor Details

SetBasedBatchProcessor

public SetBasedBatchProcessor(BJ batchJob,
 Supplier<Set<E>> batchFactory,
 int maxBatchSize)

Deprecated.

SetBasedBatchProcessor

public SetBasedBatchProcessor(BJ batchJob,
 int maxBatchSize)

Deprecated.

SetBasedBatchProcessor

public SetBasedBatchProcessor(int maxBatchSize)

Deprecated.

SetBasedBatchProcessor

public SetBasedBatchProcessor()

Deprecated.