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, options, recordEmitter, splitFetcherManager

Constructor Summary

Constructors

Constructor	Description
IcebergSourceReader(IcebergSourceReaderMetrics metrics, ReaderFunction<T> readerFunction, 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, 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(IcebergSourceReaderMetrics metrics,
                           ReaderFunction<T> readerFunction,
                           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>