DataIteratorReaderFunction

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:

RowDataReaderFunction
```
public abstract class DataIteratorReaderFunction<T>
extends java.lang.Object
implements ReaderFunction<T>
```
A ReaderFunction implementation that uses DataIterator.

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)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Function
andThen, compose

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 interface java.util.function.Function<IcebergSourceSplit,CloseableIterator<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<RecordAndPosition<T>>>>