Package org.apache.iceberg.util
Class WapUtil
- java.lang.Object
-
- org.apache.iceberg.util.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.
-
-
-
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 currentmetadata
for the target tablewapSnapshotId
- 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
-
-