Class BaseMetastoreOperations

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected 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.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • BaseMetastoreOperations

        public BaseMetastoreOperations()
    • Method Detail

      • checkCommitStatus

        protected 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