@FunctionalInterface
public interface DataIteratorBatcher<T>
extends java.io.Serializable
RecordsWithSplitIds<RecordAndPosition<T>>
, as FLIP-27's SplitReader.fetch()
returns
batched records.Modifier and Type | Method and Description |
---|---|
CloseableIterator<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<RecordAndPosition<T>>> |
batch(java.lang.String splitId,
DataIterator<T> inputIterator) |
CloseableIterator<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<RecordAndPosition<T>>> batch(java.lang.String splitId, DataIterator<T> inputIterator)