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 batchedRecordsWithSplitIds<RecordAndPosition<T>>
, as FLIP-27'sSplitReader.fetch()
returns batched records.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description CloseableIterator<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<RecordAndPosition<T>>>
batch(java.lang.String splitId, DataIterator<T> inputIterator)
-
-
-
Method Detail
-
batch
CloseableIterator<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<RecordAndPosition<T>>> batch(java.lang.String splitId, DataIterator<T> inputIterator)
-
-