org.apache.paimon.flink.sink

Class LogOffsetCommittable

java.lang.Object

org.apache.paimon.flink.sink.LogOffsetCommittable

public class LogOffsetCommittable
extends Object

Log offset committable for a bucket.

Constructor Summary

Constructors

Constructor and Description
LogOffsetCommittable(int bucket, long offset)

Method Summary

Modifier and Type	Method and Description
int	bucket()
boolean	equals(Object o)
static LogOffsetCommittable	fromBytes(byte[] bytes)
int	hashCode()
long	offset()
byte[]	toBytes()

Methods inherited from class java.lang.Object

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

Constructor Detail

LogOffsetCommittable

public LogOffsetCommittable(int bucket,
                            long offset)

Method Detail

bucket

public int bucket()

offset

public long offset()

toBytes

public byte[] toBytes()

fromBytes

public static LogOffsetCommittable fromBytes(byte[] bytes)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object