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

Class CollectionBatchCollector<C extends Collection<E>,E>

java.lang.Object

uk.ac.ebi.utils.threading.batchproc.AbstractSizedBatchCollector<C>

uk.ac.ebi.utils.threading.batchproc.collectors.CollectionBatchCollector<C,E>

Type Parameters:

C -

E -

All Implemented Interfaces:

BatchCollector<C>, ItemizedBatchCollector<C,E>, ItemizedSizedBatchCollector<C,E>, SizedBatchCollector<C>

Direct Known Subclasses:

ListBatchCollector, SetBatchCollector

@Deprecated
public abstract class CollectionBatchCollector<C extends Collection<E>,E>
extends AbstractSizedBatchCollector<C>
implements ItemizedSizedBatchCollector<C,E>

Deprecated.

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

Collectors of this type are dedicated to Java collections.

Author:

brandizi

Date:

25 Nov 2019

Constructor Summary

Constructors

Constructor	Description
CollectionBatchCollector(Supplier<C> batchFactory)	Deprecated. Default size is inherited by AbstractSizedBatchCollector.
CollectionBatchCollector(Supplier<C> batchFactory, int maxBatchSize)	Deprecated.

Method Summary

Modifier and Type	Method	Description
BiConsumer<C,E>	accumulator()	Deprecated.
Supplier<C>	batchFactory()	Deprecated.
Function<C,Long>	batchSizer()	Deprecated.

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

maxBatchSize, setMaxBatchSize

Methods inherited from class java.lang.Object

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

Methods inherited from interface uk.ac.ebi.utils.threading.batchproc.SizedBatchCollector

batchReadyFlag, maxBatchSize

Constructor Details

CollectionBatchCollector

public CollectionBatchCollector(Supplier<C> batchFactory)

Deprecated.

Default size is inherited by AbstractSizedBatchCollector.

CollectionBatchCollector

public CollectionBatchCollector(Supplier<C> batchFactory,
 int maxBatchSize)

Deprecated.

Method Details

batchFactory

public Supplier<C> batchFactory()

Deprecated.

Specified by:

batchFactory in interface BatchCollector<C extends Collection<E>>

accumulator

public BiConsumer<C,E> accumulator()

Deprecated.

Specified by:

accumulator in interface ItemizedBatchCollector<C extends Collection<E>,E>

batchSizer

public Function<C,Long> batchSizer()

Deprecated.

Specified by:

batchSizer in interface SizedBatchCollector<C extends Collection<E>>