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

Class ShardDeltaFiles

java.lang.Object

org.apache.beam.sdk.io.iceberg.cdc.sink.ShardDeltaFiles

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

Holds the serialized metadata for DataFiles and DeleteFiles of one (destination, shard, window) group, plus the source sequence range the bundle covers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ShardDeltaFiles.Builder

Constructor Summary

Constructors

Constructor	Description
ShardDeltaFiles()

Method Summary

Modifier and Type	Method	Description
static ShardDeltaFiles.Builder	builder()
abstract List<SerializableDataFile>	getDataFiles()	Reconstructed into live DataFiles at commit time.
abstract List<SerializableDeleteFile>	getDeleteFiles()	Reconstructed into live DeleteFiles at commit time.
abstract long	getMaxSequenceNumber()	The maximum source sequence number covered by this bundle.
abstract long	getMinSequenceNumber()	The minimum source sequence number covered by this bundle.
abstract String	getTableIdentifierString()

Methods inherited from class java.lang.Object

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

Constructor Details

ShardDeltaFiles

public ShardDeltaFiles()

Method Details

getTableIdentifierString

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

getDataFiles

@SchemaFieldNumber("1")
public abstract List<SerializableDataFile> getDataFiles()

Reconstructed into live DataFiles at commit time.

getDeleteFiles

@SchemaFieldNumber("2")
public abstract List<SerializableDeleteFile> getDeleteFiles()

Reconstructed into live DeleteFiles at commit time.

getMinSequenceNumber

@SchemaFieldNumber("3")
public abstract long getMinSequenceNumber()

The minimum source sequence number covered by this bundle.

getMaxSequenceNumber

@SchemaFieldNumber("4")
public abstract long getMaxSequenceNumber()

The maximum source sequence number covered by this bundle.

builder

public static ShardDeltaFiles.Builder builder()