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.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.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.FlinkSinkBuilder
- 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.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.flink.api.common.typeinfo.TypeInformation<T> (implements java.io.Serializable)
- org.apache.flink.api.common.typeutils.TypeSerializer<T> (implements java.io.Serializable)
- org.apache.flink.core.io.SimpleVersionedSerializerTypeSerializerProxy<T>
- org.apache.paimon.flink.sink.WrappedManifestCommittableSerializer (implements org.apache.paimon.data.serializer.VersionedSerializer<T>)
Interface Hierarchy
Enum Hierarchy
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.