Package org.apache.paimon.table.sink

Interface Summary

Interface	Description
BatchTableCommit	A TableCommit for batch processing.
BatchTableWrite	A TableWrite for batch processing.
BatchWriteBuilder	An interface for building the BatchTableWrite and BatchTableCommit.
ChannelComputer<T>	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<T>	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<T>	Extractor to extract partition and trimmed primary key.
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.
TableWrite	Write of Table to provide InternalRow writing.
TableWriteImpl.RecordExtractor<T>	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.

Class Summary

Class	Description
AppendCompactTaskSerializer	Serializer for AppendCompactTask.
AppendTableRowKeyExtractor	Unaware bucket table put all records into bucket 0 (for comparability with old design).
BatchWriteBuilderImpl	Implementation for WriteBuilder.
CallbackUtils	Utils to load callbacks.
CommitMessageImpl	File committable for sink.
CommitMessageLegacyV2Serializer	A legacy version serializer for CommitMessage.
CommitMessageSerializer	VersionedSerializer for CommitMessage.
DynamicBucketRowKeyExtractor	KeyAndBucketExtractor for InternalRow, just throws error when extract bucket from dynamic row.
FixedBucketRowKeyExtractor	KeyAndBucketExtractor for InternalRow.
FixedBucketWriteSelector	A WriteSelector for BucketMode.HASH_FIXED.
MultiTableCompactionTaskSerializer	Serializer for MultiTableAppendCompactTask.
PostponeBucketRowKeyExtractor	RowKeyExtractor for postpone bucket tables.
RowKeyExtractor	KeyAndBucketExtractor for InternalRow.
RowKindGenerator	Generate row kind.
RowPartitionKeyExtractor	A PartitionKeyExtractor to InternalRow.
SinkRecord	A sink record contains key, row and partition, bucket information.
StreamWriteBuilderImpl	Implementation for WriteBuilder.
TableCommitImpl	An abstraction layer above FileStoreCommit to provide snapshot commit and expiration.
TableWriteImpl<T>	TableWrite implementation.