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

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
abstract IcebergWriteSchemaTransformProvider.Configuration	build()
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setCatalogName(java.lang.String catalogName)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setCatalogProperties(java.util.Map<java.lang.String,java.lang.String> catalogProperties)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setConfigProperties(java.util.Map<java.lang.String,java.lang.String> confProperties)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setDrop(java.util.List<java.lang.String> drop)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setKeep(java.util.List<java.lang.String> keep)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setOnly(java.lang.String only)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setTable(java.lang.String table)
abstract IcebergWriteSchemaTransformProvider.Configuration.Builder	setTriggeringFrequencySeconds(java.lang.Integer triggeringFrequencySeconds)

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

setTable

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

setCatalogName

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

setCatalogProperties

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

setConfigProperties

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

setTriggeringFrequencySeconds

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

setKeep

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

setDrop

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

setOnly

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

build

public abstract IcebergWriteSchemaTransformProvider.Configuration build()