org.apache.paimon.table.sink

Class CommitMessageImpl

java.lang.Object

org.apache.paimon.table.sink.CommitMessageImpl

All Implemented Interfaces:

Serializable, CommitMessage

public class CommitMessageImpl
extends Object
implements CommitMessage

File committable for sink.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CommitMessageImpl(BinaryRow partition, int bucket, Integer totalBuckets, DataIncrement dataIncrement, CompactIncrement compactIncrement)
CommitMessageImpl(BinaryRow partition, int bucket, Integer totalBuckets, DataIncrement dataIncrement, CompactIncrement compactIncrement, IndexIncrement indexIncrement)

Method Summary

Modifier and Type	Method and Description
int	bucket() Bucket of this commit message.
CompactIncrement	compactIncrement()
boolean	equals(Object o)
int	hashCode()
IndexIncrement	indexIncrement()
boolean	isEmpty()
DataIncrement	newFilesIncrement()
BinaryRow	partition() Partition of this commit message.
String	toString()
Integer	totalBuckets() Total number of buckets in this partition.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

CommitMessageImpl

@VisibleForTesting
public CommitMessageImpl(BinaryRow partition,
                                            int bucket,
                                            @Nullable
                                            Integer totalBuckets,
                                            DataIncrement dataIncrement,
                                            CompactIncrement compactIncrement)

CommitMessageImpl

public CommitMessageImpl(BinaryRow partition,
                         int bucket,
                         @Nullable
                         Integer totalBuckets,
                         DataIncrement dataIncrement,
                         CompactIncrement compactIncrement,
                         IndexIncrement indexIncrement)

Method Detail

partition

public BinaryRow partition()

Description copied from interface: CommitMessage

Partition of this commit message.

Specified by:

partition in interface CommitMessage

bucket

public int bucket()

Description copied from interface: CommitMessage

Bucket of this commit message.

Specified by:

bucket in interface CommitMessage

totalBuckets

@Nullable
public Integer totalBuckets()

Description copied from interface: CommitMessage

Total number of buckets in this partition.

Specified by:

totalBuckets in interface CommitMessage

newFilesIncrement

public DataIncrement newFilesIncrement()

compactIncrement

public CompactIncrement compactIncrement()

indexIncrement

public IndexIncrement indexIncrement()

isEmpty

public boolean isEmpty()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object