Package org.apache.iceberg.flink.source.reader

Class IcebergSourceReader<T>

java.lang.Object

org.apache.flink.connector.base.source.reader.SourceReaderBase<E,T,SplitT,SplitStateT>

org.apache.flink.connector.base.source.reader.SingleThreadMultiplexSourceReaderBase<RecordAndPosition<T>,T,IcebergSourceSplit,IcebergSourceSplit>

org.apache.iceberg.flink.source.reader.IcebergSourceReader<T>

All Implemented Interfaces:

java.lang.AutoCloseable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.api.connector.source.SourceReader<T,IcebergSourceSplit>

@Internal
public class IcebergSourceReader<T>
extends org.apache.flink.connector.base.source.reader.SingleThreadMultiplexSourceReaderBase<RecordAndPosition<T>,T,IcebergSourceSplit,IcebergSourceSplit>

Field Summary

Fields inherited from class org.apache.flink.connector.base.source.reader.SourceReaderBase

config, context, eofRecordEvaluator, options, recordEmitter, splitFetcherManager

Constructor Summary

Constructors

Constructor	Description
IcebergSourceReader(SerializableRecordEmitter<T> emitter, IcebergSourceReaderMetrics metrics, ReaderFunction<T> readerFunction, SerializableComparator<IcebergSourceSplit> splitComparator, org.apache.flink.api.connector.source.SourceReaderContext context)

Method Summary

Modifier and Type	Method	Description
protected IcebergSourceSplit	initializedState(IcebergSourceSplit split)
protected void	onSplitFinished(java.util.Map<java.lang.String,IcebergSourceSplit> finishedSplitIds)
void	start()
protected IcebergSourceSplit	toSplitType(java.lang.String splitId, IcebergSourceSplit splitState)

Methods inherited from class org.apache.flink.connector.base.source.reader.SourceReaderBase

addSplits, close, getNumberOfCurrentlyAssignedSplits, handleSourceEvents, isAvailable, notifyNoMoreSplits, pauseOrResumeSplits, pollNext, snapshotState

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener

notifyCheckpointAborted

Methods inherited from interface org.apache.flink.api.connector.source.SourceReader

notifyCheckpointComplete

Constructor Detail

IcebergSourceReader

public IcebergSourceReader(SerializableRecordEmitter<T> emitter,
                           IcebergSourceReaderMetrics metrics,
                           ReaderFunction<T> readerFunction,
                           SerializableComparator<IcebergSourceSplit> splitComparator,
                           org.apache.flink.api.connector.source.SourceReaderContext context)

Method Detail

start

public void start()

Specified by:

start in interface org.apache.flink.api.connector.source.SourceReader<T,IcebergSourceSplit>

Overrides:

start in class org.apache.flink.connector.base.source.reader.SourceReaderBase<RecordAndPosition<T>,T,IcebergSourceSplit,IcebergSourceSplit>

onSplitFinished

protected void onSplitFinished(java.util.Map<java.lang.String,IcebergSourceSplit> finishedSplitIds)

Specified by:

onSplitFinished in class org.apache.flink.connector.base.source.reader.SourceReaderBase<RecordAndPosition<T>,T,IcebergSourceSplit,IcebergSourceSplit>

initializedState

protected IcebergSourceSplit initializedState(IcebergSourceSplit split)

Specified by:

initializedState in class org.apache.flink.connector.base.source.reader.SourceReaderBase<RecordAndPosition<T>,T,IcebergSourceSplit,IcebergSourceSplit>

toSplitType

protected IcebergSourceSplit toSplitType(java.lang.String splitId,
                                         IcebergSourceSplit splitState)

Specified by:

toSplitType in class org.apache.flink.connector.base.source.reader.SourceReaderBase<RecordAndPosition<T>,T,IcebergSourceSplit,IcebergSourceSplit>