org.apache.iceberg.flink.source.reader

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:

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 and Description
DataIteratorReaderFunction(DataIteratorBatcher<T> batcher)

Method Summary

Modifier and Type	Method and 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, identity

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