Package org.apache.iceberg.util

Class WapUtil

  • public class WapUtil
extends java.lang.Object

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static java.lang.String publishedWapId​(Snapshot snapshot)  
      static java.lang.String stagedWapId​(Snapshot snapshot)  
      static java.lang.String validateWapPublish​(TableMetadata current, long wapSnapshotId)
      Check if a given staged snapshot's associated wap-id was already published.

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • stagedWapId

        public static java.lang.String stagedWapId​(Snapshot snapshot)

      • publishedWapId

        public static java.lang.String publishedWapId​(Snapshot snapshot)

      • validateWapPublish

        public static java.lang.String validateWapPublish​(TableMetadata current,
                                                  long wapSnapshotId)
        Check if a given staged snapshot's associated wap-id was already published. Does not fail for non-WAP workflows.
        Parameters:
        current - the current metadata for the target table
        wapSnapshotId - a snapshot id which could have been staged and is associated with a wap id
        Returns:
        the WAP ID that will be published, if the snapshot has one