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

Class ChangelogDescriptor

java.lang.Object

org.apache.beam.sdk.io.iceberg.cdc.ChangelogDescriptor

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

Descriptor for a set of SerializableChangelogTasks.

This carries commit-sourced metadata for all rows produced from the task group. These values are not read from data files; they are appended to final CDC output rows by CdcOutputUtils.outputRow(java.util.List<java.lang.String>, org.apache.beam.sdk.schemas.Schema, org.apache.beam.sdk.io.iceberg.cdc.ChangelogDescriptor, org.apache.beam.sdk.values.ValueKind, org.apache.beam.sdk.values.Row) when requested.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ChangelogDescriptor.Builder

Constructor Summary

Constructors

Constructor	Description
ChangelogDescriptor()

Method Summary

Modifier and Type	Method	Description
static ChangelogDescriptor.Builder	builder()
static SchemaCoder<ChangelogDescriptor>	coder(Schema overlapSchema)
abstract long	getCommitSnapshotId()
abstract @Nullable Row	getOverlapLower()
abstract @Nullable Row	getOverlapUpper()
abstract long	getSnapshotSequenceNumber()
abstract String	getTableIdentifierString()

Methods inherited from class java.lang.Object

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

Constructor Details

ChangelogDescriptor

public ChangelogDescriptor()

Method Details

builder

public static ChangelogDescriptor.Builder builder()

coder

public static SchemaCoder<ChangelogDescriptor> coder(Schema overlapSchema)

getTableIdentifierString

@SchemaFieldNumber("0")
public abstract String getTableIdentifierString()

getSnapshotSequenceNumber

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

getCommitSnapshotId

@SchemaFieldNumber("2")
public abstract long getCommitSnapshotId()

getOverlapLower

@SchemaFieldNumber("3")
public abstract @Nullable Row getOverlapLower()

getOverlapUpper

@SchemaFieldNumber("4")
public abstract @Nullable Row getOverlapUpper()