Package org.apache.beam.sdk.io.iceberg

Class SnapshotInfo

java.lang.Object

org.apache.beam.sdk.io.iceberg.SnapshotInfo

@DefaultSchema(AutoValueSchema.class)
public abstract class SnapshotInfo
extends Object

This is an AutoValue representation of an Iceberg Snapshot.

Note: this only includes the subset of fields in Snapshot that are Beam Schema-compatible.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SnapshotInfo.Builder

Constructor Summary

Constructors

Constructor	Description
SnapshotInfo()

Method Summary

Modifier and Type	Method	Description
static SnapshotInfo.Builder	builder()
static SnapshotInfo	fromSnapshot(org.apache.iceberg.Snapshot snapshot)
static SnapshotInfo	fromSnapshot(org.apache.iceberg.Snapshot snapshot, String tableIdentifier)
abstract String	getManifestListLocation()
abstract String	getOperation()
abstract Long	getParentId()
abstract Integer	getSchemaId()
abstract long	getSequenceNumber()
abstract long	getSnapshotId()
abstract Map<String,String>	getSummary()
org.apache.iceberg.catalog.TableIdentifier	getTableIdentifier()
abstract String	getTableIdentifierString()
abstract long	getTimestampMillis()
Row	toRow()

Methods inherited from class java.lang.Object

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

Constructor Details

SnapshotInfo

public SnapshotInfo()

Method Details

fromSnapshot

public static SnapshotInfo fromSnapshot(org.apache.iceberg.Snapshot snapshot)

fromSnapshot

public static SnapshotInfo fromSnapshot(org.apache.iceberg.Snapshot snapshot,
 @Nullable
 String tableIdentifier)

toRow

public Row toRow()

builder

public static SnapshotInfo.Builder builder()

getTableIdentifier

@SchemaIgnore
public org.apache.iceberg.catalog.TableIdentifier getTableIdentifier()

getSequenceNumber

@SchemaFieldNumber("0")
public abstract long getSequenceNumber()

getSnapshotId

@SchemaFieldNumber("1")
public abstract long getSnapshotId()

getParentId

@SchemaFieldNumber("2")
@Nullable
public abstract Long getParentId()

getTimestampMillis

@SchemaFieldNumber("3")
public abstract long getTimestampMillis()

getOperation

@SchemaFieldNumber("4")
@Nullable
public abstract String getOperation()

getSummary

@SchemaFieldNumber("5")
@Nullable
public abstract Map<String,String> getSummary()

getManifestListLocation

@SchemaFieldNumber("6")
@Nullable
public abstract String getManifestListLocation()

getSchemaId

@SchemaFieldNumber("7")
@Nullable
public abstract Integer getSchemaId()

getTableIdentifierString

@SchemaFieldNumber("8")
@Nullable
public abstract String getTableIdentifierString()