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

Class IcebergWriteSchemaTransformProvider.Configuration.Builder

java.lang.Object

org.apache.beam.sdk.io.iceberg.IcebergWriteSchemaTransformProvider.Configuration.Builder

Enclosing class:

IcebergWriteSchemaTransformProvider.Configuration

public abstract static class IcebergWriteSchemaTransformProvider.Configuration.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
abstract IcebergWriteSchemaTransformProvider.Configuration	build()
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setAllowedLatenessSeconds(Integer allowedLatenessSeconds)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setAutosharding(Boolean autosharding)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setCatalogName(String catalogName)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setCatalogProperties(Map<String,String> catalogProperties)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setChangeTypeColumn(String changeTypeColumn)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setChangeTypeMap(Map<String,String> changeTypeMap)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setConfigProperties(Map<String,String> confProperties)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setDirectWriteByteLimit(Integer directWriteByteLimit)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setDistributionMode(String mode)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setDrop(List<String> drop)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setEqualityColumns(List<String> equalityColumns)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setErrorHandling(ErrorHandling errorHandling)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setKeep(List<String> keep)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setMaximumTableCacheSize(Integer maximumTableCacheSize)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setMode(String mode)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setNumShards(Integer numShards)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setOnly(String only)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setPartitionFields(List<String> partitionFields)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setSequenceNumberColumn(String sequenceNumberColumn)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setShardsPerPartition(Integer shardsPerPartition)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setSinkId(String sinkId)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setSnapshotProperties(Map<String,String> snapshotProperties)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setSorterMemoryMb(Integer sorterMemoryMb)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setSortFields(List<String> sortFields)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setTable(String table)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setTableCachePollingBuckets(Integer pollingBuckets)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setTableCacheRefreshIntervalSeconds(Integer tableCacheRefreshIntervalSeconds)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setTableProperties(Map<String,String> tableProperties)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setTokenHeartbeatSeconds(Integer tokenHeartbeatSeconds)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setTriggeringFrequencySeconds(Integer triggeringFrequencySeconds)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setUpsert(Boolean upsert)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setUseSideInputTableCache(Boolean useSideInputTableCache)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setWriteProperties(Map<String,String> writeProperties)

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

setTable

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setTable(String table)

setCatalogName

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setCatalogName(String catalogName)

setCatalogProperties

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setCatalogProperties(Map<String,String> catalogProperties)

setConfigProperties

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setConfigProperties(Map<String,String> confProperties)

setTriggeringFrequencySeconds

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setTriggeringFrequencySeconds(Integer triggeringFrequencySeconds)

setDirectWriteByteLimit

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setDirectWriteByteLimit(Integer directWriteByteLimit)

setKeep

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setKeep(List<String> keep)

setDrop

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setDrop(List<String> drop)

setOnly

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setOnly(String only)

setPartitionFields

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setPartitionFields(List<String> partitionFields)

setTableProperties

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setTableProperties(Map<String,String> tableProperties)

setSortFields

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setSortFields(List<String> sortFields)

setDistributionMode

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setDistributionMode(String mode)

setAutosharding

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setAutosharding(Boolean autosharding)

setWriteProperties

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setWriteProperties(Map<String,String> writeProperties)

setUseSideInputTableCache

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setUseSideInputTableCache(Boolean useSideInputTableCache)

setTableCacheRefreshIntervalSeconds

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setTableCacheRefreshIntervalSeconds(Integer tableCacheRefreshIntervalSeconds)

setMaximumTableCacheSize

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setMaximumTableCacheSize(Integer maximumTableCacheSize)

setTableCachePollingBuckets

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setTableCachePollingBuckets(Integer pollingBuckets)

setMode

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setMode(String mode)

setSequenceNumberColumn

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setSequenceNumberColumn(String sequenceNumberColumn)

setChangeTypeColumn

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setChangeTypeColumn(String changeTypeColumn)

setChangeTypeMap

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setChangeTypeMap(Map<String,String> changeTypeMap)

setUpsert

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setUpsert(Boolean upsert)

setEqualityColumns

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setEqualityColumns(List<String> equalityColumns)

setNumShards

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setNumShards(Integer numShards)

setShardsPerPartition

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setShardsPerPartition(Integer shardsPerPartition)

setAllowedLatenessSeconds

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setAllowedLatenessSeconds(Integer allowedLatenessSeconds)

setSinkId

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setSinkId(String sinkId)

setTokenHeartbeatSeconds

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setTokenHeartbeatSeconds(Integer tokenHeartbeatSeconds)

setSnapshotProperties

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setSnapshotProperties(Map<String,String> snapshotProperties)

setErrorHandling

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setErrorHandling(ErrorHandling errorHandling)

setSorterMemoryMb

public abstract IcebergWriteSchemaTransformProvider.Configuration.Builder setSorterMemoryMb(Integer sorterMemoryMb)

build

public abstract IcebergWriteSchemaTransformProvider.Configuration build()