org.apache.paimon.flink.sink

Class Committable

java.lang.Object

org.apache.paimon.flink.sink.Committable

public class Committable
extends Object

Committable produced by PrepareCommitOperator.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Committable.Kind Kind of the produced Committable.

Constructor Summary

Constructors

Constructor and Description
Committable(long checkpointId, Committable.Kind kind, Object wrappedCommittable)

Method Summary

Modifier and Type	Method and Description
long	checkpointId()
Committable.Kind	kind()
String	toString()
Object	wrappedCommittable()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

Committable

public Committable(long checkpointId,
                   Committable.Kind kind,
                   Object wrappedCommittable)

Method Detail

checkpointId

public long checkpointId()

kind

public Committable.Kind kind()

wrappedCommittable

public Object wrappedCommittable()

toString

public String toString()

Overrides:

toString in class Object