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

Interface BatchCollector<B>

Type Parameters:
B - the type of batch that the collector manages.
All Known Subinterfaces:
ItemizedBatchCollector<B,E>, ItemizedSizedBatchCollector<B,E>, SizedBatchCollector<B>
All Known Implementing Classes:
AbstractSizedBatchCollector, CollectionBatchCollector, ListBatchCollector, SetBatchCollector
@Deprecated public interface BatchCollector<B>
Deprecated.
the functionality available in this package is provided by project Reactor and we recommend to switch to that. @see ReactorUtils

The Batch Collector

A batch collector is a container of methods to manage batches during the operations of BatchProcessor. This default interface offers a batch factory, used to obtain a new batch when needed, and a ready flag, which establishes if a batch is ready for being processed (eg, it's full wrt a given size). Significant specific sub-interfaces are the sized-based collectors, the item-based one and their intersection. Due to some similarity, batch collectors are named after Java stream collectors.
Author:
brandizi
Date:
23 Nov 2019

  • Method Details

    • batchFactory

      Supplier<B> batchFactory()
      Deprecated.

    • batchReadyFlag

      Predicate<B> batchReadyFlag()
      Deprecated.