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

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

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

All Implemented Interfaces:: 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(Map<String,IcebergSourceSplit> finishedSplitIds)

void

start()

protected IcebergSourceSplit

toSplitType(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 Details
- IcebergSourceReader
  
  public IcebergSourceReader(SerializableRecordEmitter<T> emitter, IcebergSourceReaderMetrics metrics, ReaderFunction<T> readerFunction, SerializableComparator<IcebergSourceSplit> splitComparator, org.apache.flink.api.connector.source.SourceReaderContext context)
Method Details
- 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(Map<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(String splitId, IcebergSourceSplit splitState)
  
  Specified by:
  
  toSplitType in class org.apache.flink.connector.base.source.reader.SourceReaderBase<RecordAndPosition<T>,T,IcebergSourceSplit,IcebergSourceSplit>

Class IcebergSourceReader<T>

Field Summary