Package org.apache.iceberg
Class BaseMetastoreOperations
- java.lang.Object
- 
- org.apache.iceberg.BaseMetastoreOperations
 
- 
- Direct Known Subclasses:
- BaseMetastoreTableOperations,- BaseViewOperations
 
 public abstract class BaseMetastoreOperations extends java.lang.Object
- 
- 
Nested Class SummaryNested Classes Modifier and Type Class Description static classBaseMetastoreOperations.CommitStatus
 - 
Constructor SummaryConstructors Constructor Description BaseMetastoreOperations()
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description protected BaseMetastoreOperations.CommitStatuscheckCommitStatus(java.lang.String tableOrViewName, java.lang.String newMetadataLocation, java.util.Map<java.lang.String,java.lang.String> properties, java.util.function.Supplier<java.lang.Boolean> commitStatusSupplier)Attempt to load the content and see if any current or past metadata location matches the one we were attempting to set.
 
- 
- 
- 
Method Detail- 
checkCommitStatusprotected BaseMetastoreOperations.CommitStatus checkCommitStatus(java.lang.String tableOrViewName, java.lang.String newMetadataLocation, java.util.Map<java.lang.String,java.lang.String> properties, java.util.function.Supplier<java.lang.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
 
 
- 
 
-