Uses of Package
org.apache.paimon.table.sink

Packages that use org.apache.paimon.table.sink

Package	Description
org.apache.paimon
org.apache.paimon.append
org.apache.paimon.crosspartition
org.apache.paimon.flink.clone
org.apache.paimon.flink.compact
org.apache.paimon.flink.kafka
org.apache.paimon.flink.lookup
org.apache.paimon.flink.service
org.apache.paimon.flink.sink
org.apache.paimon.flink.sink.cdc
org.apache.paimon.flink.sink.index
org.apache.paimon.hive.migrate
org.apache.paimon.iceberg
org.apache.paimon.manifest
org.apache.paimon.metastore
org.apache.paimon.migrate
org.apache.paimon.operation
org.apache.paimon.privilege
org.apache.paimon.table
org.apache.paimon.table.sink
org.apache.paimon.tag
org.apache.paimon.utils

Classes in org.apache.paimon.table.sink used by org.apache.paimon

Class and Description
CommitCallback This callback will be called after a list of ManifestCommittables is committed.
TagCallback This callback will be called after tag operations.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.append

Class and Description
CommitMessage Commit message for partition and bucket.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.crosspartition

Class and Description
PartitionKeyExtractor Extractor to extract partition and trimmed primary key.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.flink.clone

Class and Description
ChannelComputer A utility class to compute which downstream channel a given record should be sent to.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.flink.compact

Class and Description
CommitMessage Commit message for partition and bucket.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.flink.kafka

Class and Description
SinkRecord A sink record contains key, row and partition, bucket information.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.flink.lookup

Class and Description
KeyAndBucketExtractor Utility interface to extract partition keys, bucket id, primary keys for file store (trimmedPrimaryKey) and primary keys for external log system (logPrimaryKey) from the given record.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.flink.service

Class and Description
ChannelComputer A utility class to compute which downstream channel a given record should be sent to.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.flink.sink

Class and Description
ChannelComputer A utility class to compute which downstream channel a given record should be sent to.
CommitMessageSerializer VersionedSerializer for CommitMessage.
CompactionTaskSerializer Serializer for UnawareAppendCompactionTask.
KeyAndBucketExtractor Utility interface to extract partition keys, bucket id, primary keys for file store (trimmedPrimaryKey) and primary keys for external log system (logPrimaryKey) from the given record.
PartitionKeyExtractor Extractor to extract partition and trimmed primary key.
SinkRecord A sink record contains key, row and partition, bucket information.
TableCommit Create and commit snapshots of a Table.
TableWriteImpl TableWrite implementation.
TagCallback This callback will be called after tag operations.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.flink.sink.cdc

Class and Description
ChannelComputer A utility class to compute which downstream channel a given record should be sent to.
KeyAndBucketExtractor Utility interface to extract partition keys, bucket id, primary keys for file store (trimmedPrimaryKey) and primary keys for external log system (logPrimaryKey) from the given record.
PartitionKeyExtractor Extractor to extract partition and trimmed primary key.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.flink.sink.index

Class and Description
ChannelComputer A utility class to compute which downstream channel a given record should be sent to.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.hive.migrate

Class and Description
CommitMessage Commit message for partition and bucket.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.iceberg

Class and Description
CommitCallback This callback will be called after a list of ManifestCommittables is committed.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.manifest

Class and Description
CommitMessage Commit message for partition and bucket.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.metastore

Class and Description
CommitCallback This callback will be called after a list of ManifestCommittables is committed.
TagCallback This callback will be called after tag operations.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.migrate

Class and Description
CommitMessage Commit message for partition and bucket.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.operation

Class and Description
CommitCallback This callback will be called after a list of ManifestCommittables is committed.
CommitMessage Commit message for partition and bucket.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.privilege

Class and Description
CommitCallback This callback will be called after a list of ManifestCommittables is committed.
TableCommitImpl An abstraction layer above FileStoreCommit to provide snapshot commit and expiration.
TableWriteImpl TableWrite implementation.
TagCallback This callback will be called after tag operations.
WriteSelector The WriteSelector determines to which logical downstream writers a record should be written to.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.table

Class and Description
BatchWriteBuilder An interface for building the BatchTableWrite and BatchTableCommit.
InnerTableCommit Inner TableCommit contains overwrite setter.
InnerTableWrite Inner TableWrite contains overwrite setter.
RowKeyExtractor KeyAndBucketExtractor for InternalRow.
StreamWriteBuilder An interface for building the StreamTableWrite and StreamTableCommit.
TableCommitImpl An abstraction layer above FileStoreCommit to provide snapshot commit and expiration.
TableWriteImpl TableWrite implementation.
WriteSelector The WriteSelector determines to which logical downstream writers a record should be written to.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.table.sink

Class and Description
BatchTableCommit A TableCommit for batch processing.
BatchTableWrite A TableWrite for batch processing.
BatchWriteBuilder An interface for building the BatchTableWrite and BatchTableCommit.
ChannelComputer A utility class to compute which downstream channel a given record should be sent to.
CommitCallback This callback will be called after a list of ManifestCommittables is committed.
CommitMessage Commit message for partition and bucket.
InnerTableCommit Inner TableCommit contains overwrite setter.
InnerTableWrite Inner TableWrite contains overwrite setter.
KeyAndBucketExtractor Utility interface to extract partition keys, bucket id, primary keys for file store (trimmedPrimaryKey) and primary keys for external log system (logPrimaryKey) from the given record.
PartitionKeyExtractor Extractor to extract partition and trimmed primary key.
RowKeyExtractor KeyAndBucketExtractor for InternalRow.
RowKindGenerator Generate row kind.
SinkRecord A sink record contains key, row and partition, bucket information.
StreamTableCommit A TableCommit for stream processing.
StreamTableWrite A TableWrite for stream processing.
StreamWriteBuilder An interface for building the StreamTableWrite and StreamTableCommit.
TableCommit Create and commit snapshots of a Table.
TableCommitImpl An abstraction layer above FileStoreCommit to provide snapshot commit and expiration.
TableWrite Write of Table to provide InternalRow writing.
TableWriteImpl TableWrite implementation.
TableWriteImpl.RecordExtractor Extractor to extract T from the SinkRecord.
TagCallback This callback will be called after tag operations.
WriteBuilder An interface for building the TableWrite and TableCommit.
WriteSelector The WriteSelector determines to which logical downstream writers a record should be written to.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.tag

Class and Description
TagCallback This callback will be called after tag operations.

Classes in org.apache.paimon.table.sink used by org.apache.paimon.utils

Class and Description
TagCallback This callback will be called after tag operations.