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

Field Summary

Fields

Modifier and Type	Field and Description
static SchemaCoder<SnapshotInfo>	CODER
static Schema	SCHEMA

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)
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()
abstract long	getTimestampMillis()
Row	toRow()

Methods inherited from class java.lang.Object

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

Field Detail

CODER

public static final SchemaCoder<SnapshotInfo> CODER

SCHEMA

public static final Schema SCHEMA

Constructor Detail

SnapshotInfo

public SnapshotInfo()

Method Detail

fromSnapshot

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

toRow

public Row toRow()

builder

public static SnapshotInfo.Builder builder()

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()