Interface BatchProcessor<T>

    • Method Detail

      • processBatch

        void processBatch​(Collection<? extends T> batch)
        Process the batch.
        Parameters:
        batch - the batch to process
        Throws:
        BatchInterruptedException - if the processing thread was interrupted by an exception.