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

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • 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.flink.streaming.api.operators.AbstractUdfStreamOperator<OUT,F> (implements org.apache.flink.streaming.api.operators.OutputTypeConfigurable<OUT>, org.apache.flink.streaming.api.operators.UserFunctionProvider<F>)
      • org.apache.flink.streaming.api.operators.StreamMap<IN,OUT> (implements org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>)
        • org.apache.paimon.flink.sink.StreamMapWithForwardingRecordAttributes<IN,OUT>
    • org.apache.paimon.flink.sink.CommitterOperator<CommitT,GlobalCommitT> (implements org.apache.flink.streaming.api.operators.BoundedOneInput, org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>)
    • org.apache.paimon.flink.sink.HashBucketAssignerOperator<T> (implements org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>)
    • org.apache.paimon.flink.sink.LocalMergeOperator (implements org.apache.flink.streaming.api.operators.BoundedOneInput, org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>)
    • org.apache.paimon.flink.sink.PrepareCommitOperator<IN,OUT> (implements org.apache.flink.streaming.api.operators.BoundedOneInput, org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>)
      • org.apache.paimon.flink.sink.AppendCompactWorkerOperator<IN>
        • org.apache.paimon.flink.sink.AppendBypassCompactWorkerOperator
        • org.apache.paimon.flink.sink.AppendOnlySingleTableCompactionWorkerOperator
      • org.apache.paimon.flink.sink.AppendOnlyMultiTableCompactionWorkerOperator
      • org.apache.paimon.flink.sink.MultiTablesStoreCompactOperator
      • org.apache.paimon.flink.sink.StoreCompactOperator
      • org.apache.paimon.flink.sink.TableWriteOperator<IN>
        • org.apache.paimon.flink.sink.DynamicBucketRowWriteOperator
        • org.apache.paimon.flink.sink.RowDataStoreWriteOperator
  • org.apache.paimon.flink.sink.AdaptiveParallelism
  • org.apache.paimon.flink.sink.AutoTagForSavepointCommitterOperator<CommitT,GlobalCommitT> (implements org.apache.flink.streaming.api.operators.BoundedOneInput, org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>, org.apache.flink.streaming.api.operators.SetupableStreamOperator<OUT>)
  • org.apache.paimon.flink.sink.BatchWriteGeneratorTagOperator<CommitT,GlobalCommitT> (implements org.apache.flink.streaming.api.operators.BoundedOneInput, org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>, org.apache.flink.streaming.api.operators.SetupableStreamOperator<OUT>)
  • org.apache.paimon.flink.sink.BucketsRowChannelComputer (implements org.apache.paimon.table.sink.ChannelComputer<T>)
  • org.apache.paimon.flink.sink.CombinedTableCompactorSink (implements java.io.Serializable)
  • org.apache.paimon.flink.sink.Committable
  • org.apache.paimon.flink.sink.CommittableSerializer (implements org.apache.flink.core.io.SimpleVersionedSerializer<E>)
  • org.apache.paimon.flink.sink.CommitterMetrics
  • org.apache.paimon.flink.sink.CompactionTaskSimpleSerializer (implements org.apache.flink.core.io.SimpleVersionedSerializer<E>)
  • org.apache.paimon.flink.sink.CompactorSinkBuilder
  • org.apache.paimon.flink.sink.FlinkSink<T> (implements java.io.Serializable)
    • org.apache.paimon.flink.sink.CompactorSink
    • org.apache.paimon.flink.sink.FlinkWriteSink<T>
      • org.apache.paimon.flink.sink.DynamicBucketSink<T>
        • org.apache.paimon.flink.sink.RowDynamicBucketSink
          • org.apache.paimon.flink.sink.DynamicBucketCompactSink
      • org.apache.paimon.flink.sink.FixedBucketSink
      • org.apache.paimon.flink.sink.RewriteFileIndexSink
      • org.apache.paimon.flink.sink.UnawareBucketSink<T>
        • org.apache.paimon.flink.sink.RowUnawareBucketSink
    • org.apache.paimon.flink.sink.UnawareBucketCompactionSink
  • org.apache.paimon.flink.sink.FlinkSinkBuilder
    • org.apache.paimon.flink.sink.LogFlinkSinkBuilder
    • org.apache.paimon.flink.sink.SortCompactSinkBuilder
  • org.apache.paimon.flink.sink.FlinkTableSinkBase (implements org.apache.flink.table.connector.sink.DynamicTableSink, org.apache.flink.table.connector.sink.abilities.SupportsOverwrite, org.apache.flink.table.connector.sink.abilities.SupportsPartitioning)
    • org.apache.paimon.flink.sink.SupportsRowLevelOperationFlinkTableSink (implements org.apache.flink.table.connector.sink.abilities.SupportsDeletePushDown, org.apache.flink.table.connector.sink.abilities.SupportsRowLevelDelete, org.apache.flink.table.connector.sink.abilities.SupportsRowLevelUpdate)
      • org.apache.paimon.flink.sink.FlinkTableSink (implements org.apache.flink.table.connector.sink.abilities.SupportsTruncate)
  • org.apache.paimon.flink.sink.LogOffsetCommittable
  • org.apache.paimon.flink.sink.MultiTableCommittable
  • org.apache.paimon.flink.sink.MultiTableCommittableChannelComputer (implements org.apache.paimon.table.sink.ChannelComputer<T>)
  • org.apache.paimon.flink.sink.MultiTableCommittableSerializer (implements org.apache.flink.core.io.SimpleVersionedSerializer<E>)
  • org.apache.paimon.flink.sink.NoopCommittableStateManager (implements org.apache.paimon.flink.sink.CommittableStateManager<GlobalCommitT>)
  • org.apache.paimon.flink.sink.NoopStoreSinkWriteState (implements org.apache.paimon.flink.sink.StoreSinkWriteState)
  • org.apache.paimon.flink.sink.RestoreAndFailCommittableStateManager<GlobalCommitT> (implements org.apache.paimon.flink.sink.CommittableStateManager<GlobalCommitT>)
  • org.apache.paimon.flink.sink.RewriteFileIndexSink.FileIndexProcessor
  • org.apache.paimon.flink.sink.RowAssignerChannelComputer (implements org.apache.paimon.table.sink.ChannelComputer<T>)
  • org.apache.paimon.flink.sink.RowDataChannelComputer (implements org.apache.paimon.table.sink.ChannelComputer<T>)
  • org.apache.paimon.flink.sink.RowDataKeyAndBucketExtractor (implements org.apache.paimon.table.sink.KeyAndBucketExtractor<T>)
  • org.apache.paimon.flink.sink.RowWithBucketChannelComputer (implements org.apache.paimon.table.sink.ChannelComputer<T>)
  • org.apache.paimon.flink.sink.StateUtils
  • org.apache.paimon.flink.sink.StoreCommitter (implements org.apache.paimon.flink.sink.Committer<CommitT,GlobalCommitT>)
  • org.apache.paimon.flink.sink.StoreMultiCommitter (implements org.apache.paimon.flink.sink.Committer<CommitT,GlobalCommitT>)
  • org.apache.paimon.flink.sink.StoreSinkWriteImpl (implements org.apache.paimon.flink.sink.StoreSinkWrite)
    • org.apache.paimon.flink.sink.AsyncLookupSinkWrite
    • org.apache.paimon.flink.sink.GlobalFullCompactionSinkWrite
  • org.apache.paimon.flink.sink.StoreSinkWriteState.StateValue
  • org.apache.paimon.flink.sink.StoreSinkWriteStateImpl (implements org.apache.paimon.flink.sink.StoreSinkWriteState)
  • org.apache.flink.streaming.runtime.partitioner.StreamPartitioner<T> (implements org.apache.flink.runtime.io.network.api.writer.ChannelSelector<T>, java.io.Serializable)
    • org.apache.paimon.flink.sink.FlinkStreamPartitioner<T>
  • org.apache.flink.api.common.typeinfo.TypeInformation<T> (implements java.io.Serializable)
    • org.apache.paimon.flink.sink.CommittableTypeInfo
    • org.apache.paimon.flink.sink.CompactionTaskTypeInfo
    • org.apache.paimon.flink.sink.MultiTableCommittableTypeInfo
    • org.apache.paimon.flink.sink.MultiTableCompactionTaskTypeInfo
  • org.apache.flink.api.common.typeutils.TypeSerializer<T> (implements java.io.Serializable)
    • org.apache.flink.core.io.SimpleVersionedSerializerTypeSerializerProxy<T>
      • org.apache.paimon.flink.sink.NoneCopyVersionedSerializerTypeSerializerProxy<T>
  • org.apache.paimon.flink.sink.WrappedManifestCommittableSerializer (implements org.apache.paimon.data.serializer.VersionedSerializer<T>)

Interface Hierarchy

• java.lang.AutoCloseable
  • org.apache.paimon.flink.sink.Committer<CommitT,GlobalCommitT>
• org.apache.paimon.flink.sink.Committer.Context
• org.apache.paimon.flink.sink.LogSinkFunction.WriteCallback
• java.io.Serializable
  • org.apache.paimon.flink.sink.CommittableStateManager<GlobalCommitT>
  • org.apache.paimon.flink.sink.Committer.Factory<CommitT,GlobalCommitT>
  • org.apache.flink.api.common.functions.Function
    • org.apache.flink.streaming.api.functions.sink.SinkFunction<IN> (also extends java.io.Serializable)
      • org.apache.paimon.flink.sink.LogSinkFunction
  • org.apache.flink.streaming.api.functions.sink.SinkFunction<IN> (also extends org.apache.flink.api.common.functions.Function)
    • org.apache.paimon.flink.sink.LogSinkFunction
  • org.apache.paimon.flink.sink.StoreSinkWrite.Provider
  • org.apache.paimon.flink.sink.StoreSinkWrite.WithWriteBufferProvider
• org.apache.paimon.flink.sink.StoreSinkWrite
• org.apache.paimon.flink.sink.StoreSinkWriteState
• org.apache.paimon.flink.sink.StoreSinkWriteState.StateValueFilter

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.paimon.flink.sink.Committable.Kind
    • org.apache.paimon.flink.sink.MultiTableCommittable.Kind