Hierarchy For Package org.apache.paimon.flink.source

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.flink.api.common.functions.AbstractRichFunction (implements org.apache.flink.api.common.functions.RichFunction, java.io.Serializable)
    • org.apache.flink.streaming.api.functions.source.RichSourceFunction<OUT> (implements org.apache.flink.streaming.api.functions.source.SourceFunction<T>)
      • org.apache.paimon.flink.source.BucketUnawareCompactSource
  • org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT> (implements org.apache.flink.streaming.api.operators.KeyContextHandler, java.io.Serializable, org.apache.flink.streaming.api.operators.SetupableStreamOperator<OUT>, org.apache.flink.streaming.api.operators.StreamOperator<OUT>, org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.CheckpointedStreamOperator, org.apache.flink.streaming.api.operators.YieldingOperator<OUT>)
    • org.apache.paimon.flink.source.AppendBypassCoordinateOperator<CommitT> (implements org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>, org.apache.flink.api.common.operators.ProcessingTimeService.ProcessingTimeCallback)
  • org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<OUT> (implements org.apache.flink.streaming.runtime.tasks.ProcessingTimeServiceAware, org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT>)
    • org.apache.paimon.flink.source.AppendBypassCoordinateOperatorFactory<CommitT> (implements org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<IN,OUT>)
  • org.apache.paimon.flink.source.CombinedTableCompactorSourceBuilder
  • org.apache.paimon.flink.source.CompactorSourceBuilder
  • org.apache.paimon.flink.source.ConsumerProgressCalculator
  • org.apache.paimon.flink.source.ContinuousFileSplitEnumerator (implements org.apache.flink.api.connector.source.SplitEnumerator<SplitT,CheckpointT>)
  • org.apache.paimon.flink.source.ContinuousFileSplitEnumerator.PlanWithNextSnapshotId
  • org.apache.paimon.flink.source.DynamicPartitionFilteringInfo (implements java.io.Serializable)
  • org.apache.paimon.flink.source.FileStoreSourceSplit (implements org.apache.flink.api.connector.source.SourceSplit)
  • org.apache.paimon.flink.source.FileStoreSourceSplitGenerator
  • org.apache.paimon.flink.source.FileStoreSourceSplitReader (implements org.apache.flink.connector.base.source.reader.splitreader.SplitReader<E,SplitT>)
  • org.apache.paimon.flink.source.FileStoreSourceSplitSerializer (implements org.apache.flink.core.io.SimpleVersionedSerializer<E>)
  • org.apache.paimon.flink.source.FileStoreSourceSplitState
  • org.apache.paimon.flink.source.FlinkRecordsWithSplitIds (implements org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<E>)
  • org.apache.paimon.flink.source.FlinkSource (implements org.apache.flink.api.connector.source.Source<T,SplitT,EnumChkT>)
    • org.apache.paimon.flink.source.ContinuousFileStoreSource
    • org.apache.paimon.flink.source.StaticFileStoreSource
  • org.apache.paimon.flink.source.FlinkSourceBuilder
  • org.apache.paimon.flink.source.FlinkTableSource (implements org.apache.flink.table.connector.source.ScanTableSource, org.apache.flink.table.connector.source.abilities.SupportsFilterPushDown, org.apache.flink.table.connector.source.abilities.SupportsLimitPushDown, org.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown)
    • org.apache.paimon.flink.source.BaseDataTableSource (implements org.apache.flink.table.connector.source.LookupTableSource, org.apache.flink.table.connector.source.abilities.SupportsAggregatePushDown, org.apache.flink.table.connector.source.abilities.SupportsWatermarkPushDown)
      • org.apache.paimon.flink.source.DataTableSource (implements org.apache.flink.table.connector.source.abilities.SupportsDynamicFiltering, org.apache.flink.table.connector.source.abilities.SupportsStatisticReport)
    • org.apache.paimon.flink.source.SystemTableSource
  • org.apache.paimon.flink.source.FlinkTableSource.SplitStatistics
  • org.apache.paimon.flink.source.LogHybridSourceFactory (implements org.apache.flink.connector.base.source.hybrid.HybridSource.SourceFactory<T,SourceT,FromEnumT>)
  • org.apache.paimon.flink.source.NumberSequenceRowSource (implements org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, org.apache.flink.api.connector.source.Source<T,SplitT,EnumChkT>)
  • org.apache.paimon.flink.source.NumberSequenceRowSource.NumberSequenceSplit (implements org.apache.flink.api.connector.source.lib.util.IteratorSourceSplit<E,IterT>)
  • org.apache.paimon.flink.source.OnEventWatermarkStrategy (implements org.apache.flink.api.common.eventtime.WatermarkStrategy<T>)
  • org.apache.paimon.flink.source.PendingSplitsCheckpoint
  • org.apache.paimon.flink.source.PendingSplitsCheckpointSerializer (implements org.apache.flink.core.io.SimpleVersionedSerializer<E>)
  • org.apache.paimon.flink.source.ReaderConsumeProgressEvent (implements org.apache.flink.api.connector.source.SourceEvent)
  • org.apache.paimon.flink.source.RecordLimiter
  • org.apache.paimon.flink.source.RewriteFileIndexSource (implements org.apache.flink.api.connector.source.Source<T,SplitT,EnumChkT>)
  • org.apache.paimon.flink.source.RewriteFileIndexSource.CheckpointState
  • org.apache.paimon.flink.source.RewriteFileIndexSource.Split (implements org.apache.flink.api.connector.source.SourceSplit)
  • 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.paimon.flink.source.FileStoreSourceReader
  • org.apache.paimon.flink.source.StaticFileStoreSplitEnumerator (implements org.apache.flink.api.connector.source.SplitEnumerator<SplitT,CheckpointT>, org.apache.flink.api.connector.source.SupportsHandleExecutionAttemptSourceEvent)
  • org.apache.paimon.flink.source.WatermarkAlignUtils