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

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.paimon.table.sink.BatchWriteBuilderImpl (implements org.apache.paimon.table.sink.BatchWriteBuilder)
  • org.apache.paimon.table.sink.CallbackUtils
  • org.apache.paimon.table.sink.CommitMessageImpl (implements org.apache.paimon.table.sink.CommitMessage)
  • org.apache.paimon.table.sink.CommitMessageLegacyV2Serializer
  • org.apache.paimon.table.sink.CommitMessageSerializer (implements org.apache.paimon.data.serializer.VersionedSerializer<T>)
  • org.apache.paimon.table.sink.CompactionTaskSerializer (implements org.apache.paimon.data.serializer.VersionedSerializer<T>)
  • org.apache.paimon.table.sink.FixedBucketWriteSelector (implements org.apache.paimon.table.sink.WriteSelector)
  • org.apache.paimon.table.sink.MultiTableCompactionTaskSerializer (implements org.apache.paimon.data.serializer.VersionedSerializer<T>)
  • org.apache.paimon.table.sink.RowKeyExtractor (implements org.apache.paimon.table.sink.KeyAndBucketExtractor<T>)
    • org.apache.paimon.table.sink.DynamicBucketRowKeyExtractor
    • org.apache.paimon.table.sink.FixedBucketRowKeyExtractor
    • org.apache.paimon.table.sink.UnawareBucketRowKeyExtractor
  • org.apache.paimon.table.sink.RowKindGenerator
  • org.apache.paimon.table.sink.RowPartitionKeyExtractor (implements org.apache.paimon.table.sink.PartitionKeyExtractor<T>)
  • org.apache.paimon.table.sink.SinkRecord
  • org.apache.paimon.table.sink.StreamWriteBuilderImpl (implements org.apache.paimon.table.sink.StreamWriteBuilder)
  • org.apache.paimon.table.sink.TableCommitImpl (implements org.apache.paimon.table.sink.InnerTableCommit)
  • org.apache.paimon.table.sink.TableWriteImpl<T> (implements org.apache.paimon.table.sink.InnerTableWrite, org.apache.paimon.utils.Restorable<S>)

Interface Hierarchy

• java.lang.AutoCloseable
  • org.apache.paimon.table.sink.CommitCallback
  • org.apache.paimon.table.sink.TableCommit
    • org.apache.paimon.table.sink.BatchTableCommit
      • org.apache.paimon.table.sink.InnerTableCommit (also extends org.apache.paimon.table.sink.StreamTableCommit)
    • org.apache.paimon.table.sink.StreamTableCommit
      • org.apache.paimon.table.sink.InnerTableCommit (also extends org.apache.paimon.table.sink.BatchTableCommit)
  • org.apache.paimon.table.sink.TableWrite
    • org.apache.paimon.table.sink.BatchTableWrite
      • org.apache.paimon.table.sink.InnerTableWrite (also extends org.apache.paimon.table.sink.StreamTableWrite)
    • org.apache.paimon.table.sink.StreamTableWrite
      • org.apache.paimon.table.sink.InnerTableWrite (also extends org.apache.paimon.table.sink.BatchTableWrite)
  • org.apache.paimon.table.sink.TagCallback
• org.apache.paimon.table.sink.KeyAndBucketExtractor<T>
• org.apache.paimon.table.sink.PartitionKeyExtractor<T>
• java.io.Serializable
  • org.apache.paimon.table.sink.ChannelComputer<T>
  • org.apache.paimon.table.sink.CommitMessage
  • org.apache.paimon.table.sink.WriteBuilder
    • org.apache.paimon.table.sink.BatchWriteBuilder
    • org.apache.paimon.table.sink.StreamWriteBuilder
  • org.apache.paimon.table.sink.WriteSelector
• org.apache.paimon.table.sink.TableWriteImpl.RecordExtractor<T>