Uses of Interface
org.apache.paimon.table.sink.CommitMessage

Packages that use CommitMessage

Package	Description
org.apache.paimon.append
org.apache.paimon.flink.compact
org.apache.paimon.hive.migrate
org.apache.paimon.manifest
org.apache.paimon.migrate
org.apache.paimon.operation
org.apache.paimon.table.sink

Uses of CommitMessage in org.apache.paimon.append

Methods in org.apache.paimon.append that return CommitMessage

Modifier and Type	Method and Description
CommitMessage	UnawareAppendCompactionTask.doCompact(FileStoreTable table, AppendOnlyFileStoreWrite write)

Uses of CommitMessage in org.apache.paimon.flink.compact

Fields in org.apache.paimon.flink.compact with type parameters of type CommitMessage

Modifier and Type	Field and Description
protected Queue<Future<CommitMessage>>	UnawareBucketCompactor.result

Methods in org.apache.paimon.flink.compact that return types with arguments of type CommitMessage

Modifier and Type	Method and Description
Iterable<Future<CommitMessage>>	UnawareBucketCompactor.result()

Uses of CommitMessage in org.apache.paimon.hive.migrate

Methods in org.apache.paimon.hive.migrate that return CommitMessage

Modifier and Type	Method and Description
CommitMessage	HiveMigrator.MigrateTask.call()

Uses of CommitMessage in org.apache.paimon.manifest

Methods in org.apache.paimon.manifest that return types with arguments of type CommitMessage

Modifier and Type	Method and Description
List<CommitMessage>	ManifestCommittable.fileCommittables()

Methods in org.apache.paimon.manifest with parameters of type CommitMessage

Modifier and Type	Method and Description
void	ManifestCommittable.addFileCommittable(CommitMessage commitMessage)

Constructor parameters in org.apache.paimon.manifest with type arguments of type CommitMessage

Constructor and Description
ManifestCommittable(long identifier, Long watermark, Map<Integer,Long> logOffsets, List<CommitMessage> commitMessages)

Uses of CommitMessage in org.apache.paimon.migrate

Methods in org.apache.paimon.migrate that return CommitMessage

Modifier and Type	Method and Description
static CommitMessage	FileMetaUtils.commitFile(BinaryRow partition, List<DataFileMeta> dataFileMetas)

Uses of CommitMessage in org.apache.paimon.operation

Methods in org.apache.paimon.operation that return types with arguments of type CommitMessage

Modifier and Type	Method and Description
List<CommitMessage>	FileStoreWrite.prepareCommit(boolean waitCompaction, long commitIdentifier) Prepare commit in the write.
List<CommitMessage>	AbstractFileStoreWrite.prepareCommit(boolean waitCompaction, long commitIdentifier)
List<CommitMessage>	MemoryFileStoreWrite.prepareCommit(boolean waitCompaction, long commitIdentifier)

Method parameters in org.apache.paimon.operation with type arguments of type CommitMessage

Modifier and Type	Method and Description
void	FileStoreCommitImpl.abort(List<CommitMessage> commitMessages)
void	FileStoreCommit.abort(List<CommitMessage> commitMessages) Abort an unsuccessful commit.

Uses of CommitMessage in org.apache.paimon.table.sink

Classes in org.apache.paimon.table.sink that implement CommitMessage

Modifier and Type	Class and Description
class	CommitMessageImpl File committable for sink.

Methods in org.apache.paimon.table.sink that return CommitMessage

Modifier and Type	Method and Description
CommitMessage	CommitMessageLegacyV2Serializer.deserialize(DataInputView view)
CommitMessage	CommitMessageSerializer.deserialize(int version, byte[] serialized)

Methods in org.apache.paimon.table.sink that return types with arguments of type CommitMessage

Modifier and Type	Method and Description
List<CommitMessage>	CommitMessageLegacyV2Serializer.deserializeList(DataInputView view)
List<CommitMessage>	CommitMessageSerializer.deserializeList(int version, DataInputView view)
List<CommitMessage>	TableWriteImpl.prepareCommit()
List<CommitMessage>	BatchTableWrite.prepareCommit() Prepare commit for TableCommit.
List<CommitMessage>	TableWriteImpl.prepareCommit(boolean waitCompaction, long commitIdentifier)
List<CommitMessage>	StreamTableWrite.prepareCommit(boolean waitCompaction, long commitIdentifier) Prepare commit for TableCommit.

Methods in org.apache.paimon.table.sink with parameters of type CommitMessage

Modifier and Type	Method and Description
byte[]	CommitMessageSerializer.serialize(CommitMessage obj)

Method parameters in org.apache.paimon.table.sink with type arguments of type CommitMessage

Modifier and Type	Method and Description
void	TableCommit.abort(List<CommitMessage> commitMessages) Abort an unsuccessful commit.
void	TableCommitImpl.abort(List<CommitMessage> commitMessages)
void	BatchTableCommit.commit(List<CommitMessage> commitMessages) Create a new commit.
void	TableCommitImpl.commit(List<CommitMessage> commitMessages)
void	StreamTableCommit.commit(long commitIdentifier, List<CommitMessage> commitMessages) Create a new commit.
void	TableCommitImpl.commit(long identifier, List<CommitMessage> commitMessages)
int	StreamTableCommit.filterAndCommit(Map<Long,List<CommitMessage>> commitIdentifiersAndMessages) Filter out all List<CommitMessage> which have been committed and commit the remaining ones.
int	TableCommitImpl.filterAndCommit(Map<Long,List<CommitMessage>> commitIdentifiersAndMessages)
void	CommitMessageSerializer.serializeList(List<CommitMessage> list, DataOutputView view)