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

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.iceberg.flink.source.reader.ColumnStatsWatermarkExtractor (implements java.io.Serializable, org.apache.iceberg.flink.source.reader.SplitWatermarkExtractor)
  • org.apache.iceberg.flink.source.reader.DataIteratorReaderFunction<T> (implements org.apache.iceberg.flink.source.reader.ReaderFunction<T>)
    • org.apache.iceberg.flink.source.reader.AvroGenericRecordReaderFunction
    • org.apache.iceberg.flink.source.reader.MetaDataReaderFunction
    • org.apache.iceberg.flink.source.reader.RowDataReaderFunction
  • org.apache.iceberg.flink.source.reader.IcebergSourceReaderMetrics
  • org.apache.iceberg.flink.source.reader.RecordAndPosition<T>
  • org.apache.flink.connector.base.source.reader.SourceReaderBase<E,T,SplitT,SplitStateT> (implements org.apache.flink.api.connector.source.SourceReader<T,SplitT>)
    • org.apache.flink.connector.base.source.reader.SingleThreadMultiplexSourceReaderBase<E,T,SplitT,SplitStateT>
      • org.apache.iceberg.flink.source.reader.IcebergSourceReader<T>

Interface Hierarchy

• java.util.function.Function<T,R>
  • org.apache.iceberg.flink.source.reader.ReaderFunction<T> (also extends java.io.Serializable)
• org.apache.flink.connector.base.source.reader.RecordEmitter<E,T,SplitStateT>
  • org.apache.iceberg.flink.source.reader.SerializableRecordEmitter<T> (also extends java.io.Serializable)
• java.io.Serializable
  • org.apache.iceberg.flink.source.reader.DataIteratorBatcher<T>
  • org.apache.iceberg.flink.source.reader.ReaderFunction<T> (also extends java.util.function.Function<T,R>)
  • org.apache.iceberg.flink.source.reader.SerializableRecordEmitter<T> (also extends org.apache.flink.connector.base.source.reader.RecordEmitter<E,T,SplitStateT>)
  • org.apache.iceberg.flink.source.reader.SplitWatermarkExtractor