org.apache.beam.sdk.io.iceberg

Class SnapshotInfo

java.lang.Object

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

@DefaultSchema(value=AutoValueSchema.class)
public abstract class SnapshotInfo
extends java.lang.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 and Description
static class	SnapshotInfo.Builder

Constructor Summary

Constructors

Constructor and Description
SnapshotInfo()

Method Summary

Modifier and Type	Method and Description
static SnapshotInfo.Builder	builder()
static SnapshotInfo	fromSnapshot(org.apache.iceberg.Snapshot snapshot)
static SnapshotInfo	fromSnapshot(org.apache.iceberg.Snapshot snapshot, java.lang.String tableIdentifier)
abstract java.lang.String	getManifestListLocation()
abstract java.lang.String	getOperation()
abstract java.lang.Long	getParentId()
abstract java.lang.Integer	getSchemaId()
abstract long	getSequenceNumber()
abstract long	getSnapshotId()
abstract java.util.Map<java.lang.String,java.lang.String>	getSummary()
org.apache.iceberg.catalog.TableIdentifier	getTableIdentifier()
abstract java.lang.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 Detail

SnapshotInfo

public SnapshotInfo()

Method Detail

fromSnapshot

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

fromSnapshot

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

toRow

public Row toRow()

builder

public static SnapshotInfo.Builder builder()

getTableIdentifier

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

getSequenceNumber

public abstract long getSequenceNumber()

getSnapshotId

public abstract long getSnapshotId()

getParentId

@Nullable
public abstract java.lang.Long getParentId()

getTimestampMillis

public abstract long getTimestampMillis()

getOperation

@Nullable
public abstract java.lang.String getOperation()

getSummary

@Nullable
public abstract java.util.Map<java.lang.String,java.lang.String> getSummary()

getManifestListLocation

@Nullable
public abstract java.lang.String getManifestListLocation()

getSchemaId

@Nullable
public abstract java.lang.Integer getSchemaId()

getTableIdentifierString

@Nullable
public abstract java.lang.String getTableIdentifierString()