org.apache.paimon.flink.sink

Class MultiTableCommittable

java.lang.Object

org.apache.paimon.flink.sink.MultiTableCommittable

public class MultiTableCommittable
extends Object

MultiTableCommittable produced by PrepareCommitOperator. This type of Committable will only be produced by multiplexed operators that handles data from multiple tables. Thus, the database, table, and commit user of each table is included in the committable.

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
MultiTableCommittable(String database, String table, long checkpointId, Committable.Kind kind, Object wrappedCommittable)

Method Summary

Modifier and Type	Method and Description
long	checkpointId()
static MultiTableCommittable	fromCommittable(Identifier id, Committable committable)
String	getDatabase()
String	getTable()
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

MultiTableCommittable

public MultiTableCommittable(String database,
                             String table,
                             long checkpointId,
                             Committable.Kind kind,
                             Object wrappedCommittable)

Method Detail

fromCommittable

public static MultiTableCommittable fromCommittable(Identifier id,
                                                    Committable committable)

getDatabase

public String getDatabase()

getTable

public String getTable()

checkpointId

public long checkpointId()

kind

public Committable.Kind kind()

wrappedCommittable

public Object wrappedCommittable()

toString

public String toString()

Overrides:

toString in class Object