org.apache.paimon.table.sink

Interface CommitMessage

All Superinterfaces:

Serializable

All Known Implementing Classes:

CommitMessageImpl

@Public
public interface CommitMessage
extends Serializable

Commit message for partition and bucket.

Since:

0.4.0

Method Summary

Modifier and Type	Method and Description
int	bucket() Bucket of this commit message.
BinaryRow	partition() Partition of this commit message.
Integer	totalBuckets() Total number of buckets in this partition.

Method Detail

partition

BinaryRow partition()

Partition of this commit message.

bucket

int bucket()

Bucket of this commit message.

totalBuckets

@Nullable
Integer totalBuckets()

Total number of buckets in this partition.