org.apache.iceberg.util

Class WapUtil

java.lang.Object

org.apache.iceberg.util.WapUtil

public class WapUtil
extends java.lang.Object

Method Summary

Modifier and Type	Method and 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