Package org.apache.iceberg

Class BaseMetastoreOperations

java.lang.Object

org.apache.iceberg.BaseMetastoreOperations

Direct Known Subclasses:

BaseMetastoreTableOperations, BaseViewOperations

public abstract class BaseMetastoreOperations
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	BaseMetastoreOperations.CommitStatus

Constructor Summary

Constructors

Constructor	Description
BaseMetastoreOperations()

Method Summary

Modifier and Type	Method	Description
protected BaseMetastoreOperations.CommitStatus	checkCommitStatus(String tableOrViewName, String newMetadataLocation, Map<String,String> properties, Supplier<Boolean> commitStatusSupplier)	Attempt to load the content and see if any current or past metadata location matches the one we were attempting to set.

Methods inherited from class java.lang.Object

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

Constructor Details

BaseMetastoreOperations

public BaseMetastoreOperations()

Method Details

checkCommitStatus

protected BaseMetastoreOperations.CommitStatus checkCommitStatus(String tableOrViewName,
 String newMetadataLocation,
 Map<String,String> properties,
 Supplier<Boolean> commitStatusSupplier)

Attempt to load the content and see if any current or past metadata location matches the one we were attempting to set. This is used as a last resort when we are dealing with exceptions that may indicate the commit has failed but don't have proof that this is the case. Note that all the previous locations must also be searched on the chance that a second committer was able to successfully commit on top of our commit.

Parameters:

tableOrViewName - full name of the Table/View

newMetadataLocation - the path of the new commit file

properties - properties for retry

commitStatusSupplier - check if the latest metadata presents or not using metadata location for table.

Returns:

Commit Status of Success, Failure or Unknown