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

Class CollectionBasedBatchProcessor<E,B extends Collection<E>,BC extends CollectionBatchCollector<B,E>,BJ extends Consumer<B>>

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,B,BC,BJ>

Direct Known Subclasses:

ListBasedBatchProcessor, SetBasedBatchProcessor

@Deprecated
public abstract class CollectionBasedBatchProcessor<E,B extends Collection<E>,BC extends CollectionBatchCollector<B,E>,BJ extends Consumer<B>>
extends ItemizedBatchProcessor<E,B,BC,BJ>

Deprecated.

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

An item-based batch processor that is based on Java collection batches. This is mainly an entry point for specific sub-classes, which map concrete Java collections.

Author:

brandizi

Date:

25 Nov 2019

Field Summary

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

jobLogPeriod, log

Constructor Summary

Constructors

Constructor	Description
CollectionBasedBatchProcessor()	Deprecated. This initialises with a default collection and size, like CollectionBasedBatchProcessor(Consumer), and no job (which needs to be set later via BatchProcessor.setBatchJob(Consumer)).
CollectionBasedBatchProcessor(BJ batchJob)	Deprecated. Initialises with a default collection, which should also have a default max size.
CollectionBasedBatchProcessor(BJ batchJob, BC batchCollector)	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	setMaxBatchSize(int maxBatchSize)	Deprecated. A shorthand for BatchProcessor.getBatchCollector().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

CollectionBasedBatchProcessor

public CollectionBasedBatchProcessor(BJ batchJob,
 BC batchCollector)

Deprecated.

CollectionBasedBatchProcessor

public CollectionBasedBatchProcessor(BJ batchJob)

Deprecated.

Initialises with a default collection, which should also have a default max size.

CollectionBasedBatchProcessor

public CollectionBasedBatchProcessor()

Deprecated.

This initialises with a default collection and size, like CollectionBasedBatchProcessor(Consumer), and no job (which needs to be set later via BatchProcessor.setBatchJob(Consumer)).

Method Details

setMaxBatchSize

public void setMaxBatchSize(int maxBatchSize)

Deprecated.

A shorthand for BatchProcessor.getBatchCollector().setMaxBatchSize().