WapUtil

java.lang.Object

org.apache.iceberg.util.WapUtil

public class WapUtil extends Object

Method Summary

Modifier and Type

Method

Description

static String

publishedWapId(Snapshot snapshot)

static String

stagedWapId(Snapshot snapshot)

static 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 Details
- stagedWapId
  
  public static String stagedWapId(Snapshot snapshot)
- publishedWapId
  
  public static String publishedWapId(Snapshot snapshot)
- validateWapPublish
  
  public static 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