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

Class CdcRowDescriptor

java.lang.Object

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

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

Shuffle key for bidirectional CDC rows.

The primary key isolates rows for update resolution. The snapshot sequence number and commit snapshot id carry commit-sourced metadata through ResolveChanges, where they can be appended to final output rows if requested.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CdcRowDescriptor.Builder

Constructor Summary

Constructors

Constructor	Description
CdcRowDescriptor()

Method Summary

Modifier and Type	Method	Description
static CdcRowDescriptor.Builder	builder()
static SchemaCoder<CdcRowDescriptor>	coder(Schema identifierSchema)
abstract long	getCommitSnapshotId()
abstract Row	getPrimaryKey()
abstract long	getSnapshotSequenceNumber()

Methods inherited from class java.lang.Object

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

Constructor Details

CdcRowDescriptor

public CdcRowDescriptor()

Method Details

coder

public static SchemaCoder<CdcRowDescriptor> coder(Schema identifierSchema)

builder

public static CdcRowDescriptor.Builder builder()

getSnapshotSequenceNumber

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

getCommitSnapshotId

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

getPrimaryKey

@SchemaFieldNumber("2")
public abstract Row getPrimaryKey()