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.

  • 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

      public abstract long getSequenceNumber()

    • getSnapshotId

      public abstract long getSnapshotId()

    • getParentId

      @Nullable public abstract Long getParentId()

    • getTimestampMillis

      public abstract long getTimestampMillis()

    • getOperation

      @Nullable public abstract String getOperation()

    • getSummary

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

    • getManifestListLocation

      @Nullable public abstract String getManifestListLocation()

    • getSchemaId

      @Nullable public abstract Integer getSchemaId()

    • getTableIdentifierString

      @Nullable public abstract String getTableIdentifierString()