Class 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
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      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