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

Class ShardDeltaFiles.Builder

java.lang.Object

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

Enclosing class:

ShardDeltaFiles

public abstract static class ShardDeltaFiles.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
abstract ShardDeltaFiles	build()
abstract ShardDeltaFiles.Builder	setDataFiles(List<SerializableDataFile> dataFiles)
abstract ShardDeltaFiles.Builder	setDeleteFiles(List<SerializableDeleteFile> deleteFiles)
abstract ShardDeltaFiles.Builder	setMaxSequenceNumber(long maxSequenceNumber)
abstract ShardDeltaFiles.Builder	setMinSequenceNumber(long minSequenceNumber)
abstract ShardDeltaFiles.Builder	setTableIdentifierString(String tableIdString)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

setTableIdentifierString

public abstract ShardDeltaFiles.Builder setTableIdentifierString(String tableIdString)

setDataFiles

public abstract ShardDeltaFiles.Builder setDataFiles(List<SerializableDataFile> dataFiles)

setDeleteFiles

public abstract ShardDeltaFiles.Builder setDeleteFiles(List<SerializableDeleteFile> deleteFiles)

setMinSequenceNumber

public abstract ShardDeltaFiles.Builder setMinSequenceNumber(long minSequenceNumber)

setMaxSequenceNumber

public abstract ShardDeltaFiles.Builder setMaxSequenceNumber(long maxSequenceNumber)

build

public abstract ShardDeltaFiles build()