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 java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
abstract IcebergScanConfig	build()
abstract IcebergScanConfig.Builder	setBranch(@Nullable java.lang.String branch)
abstract IcebergScanConfig.Builder	setCaseSensitive(@Nullable java.lang.Boolean caseSensitive)
abstract IcebergScanConfig.Builder	setCatalogConfig(IcebergCatalogConfig catalog)
abstract IcebergScanConfig.Builder	setFilter(@Nullable org.apache.iceberg.expressions.Expression filter)
abstract IcebergScanConfig.Builder	setFromSnapshotExclusive(@Nullable java.lang.Long fromExclusive)
abstract IcebergScanConfig.Builder	setFromSnapshotInclusive(@Nullable java.lang.Long fromInclusive)
abstract IcebergScanConfig.Builder	setFromSnapshotRefExclusive(@Nullable java.lang.String ref)
abstract IcebergScanConfig.Builder	setFromSnapshotRefInclusive(@Nullable java.lang.String ref)
abstract IcebergScanConfig.Builder	setOptions(org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableMap<java.lang.String,java.lang.String> options)
abstract IcebergScanConfig.Builder	setScanType(IcebergScanConfig.ScanType type)
abstract IcebergScanConfig.Builder	setSchema(Schema schema)
abstract IcebergScanConfig.Builder	setSnapshot(@Nullable java.lang.Long snapshot)
IcebergScanConfig.Builder	setTableIdentifier(java.lang.String... names)
abstract IcebergScanConfig.Builder	setTableIdentifier(java.lang.String tableIdentifier)
IcebergScanConfig.Builder	setTableIdentifier(org.apache.iceberg.catalog.TableIdentifier tableIdentifier)
abstract IcebergScanConfig.Builder	setTag(@Nullable java.lang.String tag)
abstract IcebergScanConfig.Builder	setTimestamp(@Nullable java.lang.Long timestamp)
abstract IcebergScanConfig.Builder	setToSnapshot(@Nullable java.lang.Long snapshot)
abstract IcebergScanConfig.Builder	setToSnapshotRef(@Nullable java.lang.String ref)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

setScanType

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

setCatalogConfig

public abstract IcebergScanConfig.Builder setCatalogConfig(IcebergCatalogConfig catalog)

setTableIdentifier

public abstract IcebergScanConfig.Builder setTableIdentifier(java.lang.String tableIdentifier)

setTableIdentifier

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

setTableIdentifier

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

setSchema

public abstract IcebergScanConfig.Builder setSchema(Schema schema)

setFilter

public abstract IcebergScanConfig.Builder setFilter(@Nullable org.apache.iceberg.expressions.Expression filter)

setCaseSensitive

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

setOptions

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

setSnapshot

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

setTimestamp

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

setFromSnapshotInclusive

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

setFromSnapshotRefInclusive

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

setFromSnapshotExclusive

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

setFromSnapshotRefExclusive

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

setToSnapshot

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

setToSnapshotRef

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

setTag

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

setBranch

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

build

public abstract IcebergScanConfig build()