@Internal public class IcebergSourceReader<T> extends org.apache.flink.connector.base.source.reader.SingleThreadMultiplexSourceReaderBase<RecordAndPosition<T>,T,IcebergSourceSplit,IcebergSourceSplit>
Constructor and Description |
---|
IcebergSourceReader(IcebergSourceReaderMetrics metrics,
ReaderFunction<T> readerFunction,
org.apache.flink.api.connector.source.SourceReaderContext context) |
Modifier and Type | Method and 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) |
addSplits, close, getNumberOfCurrentlyAssignedSplits, handleSourceEvents, isAvailable, notifyNoMoreSplits, pauseOrResumeSplits, pollNext, snapshotState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public IcebergSourceReader(IcebergSourceReaderMetrics metrics, ReaderFunction<T> readerFunction, org.apache.flink.api.connector.source.SourceReaderContext context)
public void start()
start
in interface org.apache.flink.api.connector.source.SourceReader<T,IcebergSourceSplit>
start
in class org.apache.flink.connector.base.source.reader.SourceReaderBase<RecordAndPosition<T>,T,IcebergSourceSplit,IcebergSourceSplit>
protected void onSplitFinished(java.util.Map<java.lang.String,IcebergSourceSplit> finishedSplitIds)
onSplitFinished
in class org.apache.flink.connector.base.source.reader.SourceReaderBase<RecordAndPosition<T>,T,IcebergSourceSplit,IcebergSourceSplit>
protected IcebergSourceSplit initializedState(IcebergSourceSplit split)
initializedState
in class org.apache.flink.connector.base.source.reader.SourceReaderBase<RecordAndPosition<T>,T,IcebergSourceSplit,IcebergSourceSplit>
protected IcebergSourceSplit toSplitType(java.lang.String splitId, IcebergSourceSplit splitState)
toSplitType
in class org.apache.flink.connector.base.source.reader.SourceReaderBase<RecordAndPosition<T>,T,IcebergSourceSplit,IcebergSourceSplit>