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

Class IcebergScanConfig.Builder

java.lang.Object

org.apache.beam.sdk.io.iceberg.IcebergScanConfig.Builder

Enclosing class:

IcebergScanConfig

public abstract static class IcebergScanConfig.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
abstract IcebergScanConfig	build()
abstract IcebergScanConfig.Builder	setBranch(@Nullable String branch)
abstract IcebergScanConfig.Builder	setCaseSensitive(@Nullable Boolean caseSensitive)
abstract IcebergScanConfig.Builder	setCatalogConfig(IcebergCatalogConfig catalog)
abstract IcebergScanConfig.Builder	setDropFields(@Nullable List<String> fields)
abstract IcebergScanConfig.Builder	setFilterString(@Nullable String filter)
abstract IcebergScanConfig.Builder	setFromSnapshotExclusive(@Nullable Long fromExclusive)
abstract IcebergScanConfig.Builder	setFromSnapshotInclusive(@Nullable Long fromInclusive)
abstract IcebergScanConfig.Builder	setFromSnapshotRefExclusive(@Nullable String ref)
abstract IcebergScanConfig.Builder	setFromSnapshotRefInclusive(@Nullable String ref)
abstract IcebergScanConfig.Builder	setFromTimestamp(@Nullable Long timestamp)
abstract IcebergScanConfig.Builder	setKeepFields(@Nullable List<String> fields)
abstract IcebergScanConfig.Builder	setOptions(org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableMap<String,String> options)
abstract IcebergScanConfig.Builder	setPollInterval(@Nullable Duration pollInterval)
abstract IcebergScanConfig.Builder	setScanType(IcebergScanConfig.ScanType type)
abstract IcebergScanConfig.Builder	setSchema(Schema schema)
abstract IcebergScanConfig.Builder	setSnapshot(@Nullable Long snapshot)
abstract IcebergScanConfig.Builder	setStartingStrategy(@Nullable IcebergIO.ReadRows.StartingStrategy strategy)
abstract IcebergScanConfig.Builder	setStreaming(@Nullable Boolean streaming)
abstract IcebergScanConfig.Builder	setTableIdentifier(String tableIdentifier)
IcebergScanConfig.Builder	setTableIdentifier(String... names)
IcebergScanConfig.Builder	setTableIdentifier(org.apache.iceberg.catalog.TableIdentifier tableIdentifier)
abstract IcebergScanConfig.Builder	setTag(@Nullable String tag)
abstract IcebergScanConfig.Builder	setTimestamp(@Nullable Long timestamp)
abstract IcebergScanConfig.Builder	setToSnapshot(@Nullable Long snapshot)
abstract IcebergScanConfig.Builder	setToSnapshotRef(@Nullable String ref)
abstract IcebergScanConfig.Builder	setToTimestamp(@Nullable Long timestamp)
abstract IcebergScanConfig.Builder	setUseCdc(boolean useCdc)

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

setScanType

public abstract IcebergScanConfig.Builder setScanType(IcebergScanConfig.ScanType type)

setCatalogConfig

public abstract IcebergScanConfig.Builder setCatalogConfig(IcebergCatalogConfig catalog)

setTableIdentifier

public abstract IcebergScanConfig.Builder setTableIdentifier(String tableIdentifier)

setTableIdentifier

public IcebergScanConfig.Builder setTableIdentifier(org.apache.iceberg.catalog.TableIdentifier tableIdentifier)

setTableIdentifier

public IcebergScanConfig.Builder setTableIdentifier(String... names)

setSchema

public abstract IcebergScanConfig.Builder setSchema(Schema schema)

setFilterString

public abstract IcebergScanConfig.Builder setFilterString(@Nullable String filter)

setCaseSensitive

public abstract IcebergScanConfig.Builder setCaseSensitive(@Nullable Boolean caseSensitive)

setOptions

public abstract IcebergScanConfig.Builder setOptions(org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableMap<String,String> options)

setSnapshot

public abstract IcebergScanConfig.Builder setSnapshot(@Nullable Long snapshot)

setTimestamp

public abstract IcebergScanConfig.Builder setTimestamp(@Nullable Long timestamp)

setFromSnapshotInclusive

public abstract IcebergScanConfig.Builder setFromSnapshotInclusive(@Nullable Long fromInclusive)

setFromSnapshotRefInclusive

public abstract IcebergScanConfig.Builder setFromSnapshotRefInclusive(@Nullable String ref)

setFromSnapshotExclusive

public abstract IcebergScanConfig.Builder setFromSnapshotExclusive(@Nullable Long fromExclusive)

setFromSnapshotRefExclusive

public abstract IcebergScanConfig.Builder setFromSnapshotRefExclusive(@Nullable String ref)

setToSnapshot

public abstract IcebergScanConfig.Builder setToSnapshot(@Nullable Long snapshot)

setToSnapshotRef

public abstract IcebergScanConfig.Builder setToSnapshotRef(@Nullable String ref)

setFromTimestamp

public abstract IcebergScanConfig.Builder setFromTimestamp(@Nullable Long timestamp)

setToTimestamp

public abstract IcebergScanConfig.Builder setToTimestamp(@Nullable Long timestamp)

setStartingStrategy

public abstract IcebergScanConfig.Builder setStartingStrategy(@Nullable IcebergIO.ReadRows.StartingStrategy strategy)

setUseCdc

public abstract IcebergScanConfig.Builder setUseCdc(boolean useCdc)

setStreaming

public abstract IcebergScanConfig.Builder setStreaming(@Nullable Boolean streaming)

setPollInterval

public abstract IcebergScanConfig.Builder setPollInterval(@Nullable Duration pollInterval)

setTag

public abstract IcebergScanConfig.Builder setTag(@Nullable String tag)

setBranch

public abstract IcebergScanConfig.Builder setBranch(@Nullable String branch)

setKeepFields

public abstract IcebergScanConfig.Builder setKeepFields(@Nullable List<String> fields)

setDropFields

public abstract IcebergScanConfig.Builder setDropFields(@Nullable List<String> fields)

build

public abstract IcebergScanConfig build()