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	setCatalogName(String catalogName)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setCatalogProperties(Map<String,String> catalogProperties)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setConfigProperties(Map<String,String> confProperties)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setDrop(List<String> drop)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setKeep(List<String> keep)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setOnly(String only)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setPartitionFields(List<String> partitionFields)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setTable(String table)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setTableProperties(Map<String,String> tableProperties)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setTriggeringFrequencySeconds(Integer triggeringFrequencySeconds)

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)

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)

build

public abstract IcebergWriteSchemaTransformProvider.Configuration build()