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
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.
CompactionTaskSerializer	Serializer for UnawareAppendCompactionTask.
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 MultiTableUnawareAppendCompactionTask.
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.
UnawareBucketRowKeyExtractor	Unaware bucket table put all records into bucket 0 (for comparability with old design).