Interface DataIteratorBatcher<T>

  • All Superinterfaces:
    java.io.Serializable
    Functional Interface:
    This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

    @FunctionalInterface
    public interface DataIteratorBatcher<T>
    extends java.io.Serializable
    Batcher converts iterator of T into iterator of batched RecordsWithSplitIds<RecordAndPosition<T>>, as FLIP-27's SplitReader.fetch() returns batched records.