Class DataIteratorReaderFunction<T>
- java.lang.Object
-
- org.apache.iceberg.flink.source.reader.DataIteratorReaderFunction<T>
-
- All Implemented Interfaces:
java.io.Serializable
,java.util.function.Function<IcebergSourceSplit,CloseableIterator<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<RecordAndPosition<T>>>>
,ReaderFunction<T>
- Direct Known Subclasses:
AvroGenericRecordReaderFunction
,MetaDataReaderFunction
,RowDataReaderFunction
public abstract class DataIteratorReaderFunction<T> extends java.lang.Object implements ReaderFunction<T>
AReaderFunction
implementation that usesDataIterator
.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description DataIteratorReaderFunction(DataIteratorBatcher<T> batcher)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description CloseableIterator<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<RecordAndPosition<T>>>
apply(IcebergSourceSplit split)
protected abstract DataIterator<T>
createDataIterator(IcebergSourceSplit split)
-
-
-
Constructor Detail
-
DataIteratorReaderFunction
public DataIteratorReaderFunction(DataIteratorBatcher<T> batcher)
-
-
Method Detail
-
createDataIterator
protected abstract DataIterator<T> createDataIterator(IcebergSourceSplit split)
-
apply
public CloseableIterator<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<RecordAndPosition<T>>> apply(IcebergSourceSplit split)
- Specified by:
apply
in interfacejava.util.function.Function<IcebergSourceSplit,CloseableIterator<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<RecordAndPosition<T>>>>
-
-