org.apache.paimon.metastore

Class AddPartitionCommitCallback

java.lang.Object

org.apache.paimon.metastore.AddPartitionCommitCallback

All Implemented Interfaces:

AutoCloseable, CommitCallback

public class AddPartitionCommitCallback
extends Object
implements CommitCallback

A CommitCallback to add newly created partitions to metastore.

Constructor Summary

Constructors

Constructor and Description
AddPartitionCommitCallback(PartitionHandler partitionHandler, InternalRowPartitionComputer partitionComputer)

Method Summary

Modifier and Type	Method and Description
void	call(List<ManifestEntry> committedEntries, Snapshot snapshot)
void	close()
void	retry(ManifestCommittable committable)

Methods inherited from class java.lang.Object

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

Constructor Detail

AddPartitionCommitCallback

public AddPartitionCommitCallback(PartitionHandler partitionHandler,
                                  InternalRowPartitionComputer partitionComputer)

Method Detail

call

public void call(List<ManifestEntry> committedEntries,
                 Snapshot snapshot)

Specified by:

call in interface CommitCallback

retry

public void retry(ManifestCommittable committable)

Specified by:

retry in interface CommitCallback

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception