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

Class AddFilesSchemaTransformProvider.Configuration.Builder

java.lang.Object

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

Enclosing class:

AddFilesSchemaTransformProvider.Configuration

public abstract static class AddFilesSchemaTransformProvider.Configuration.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
abstract AddFilesSchemaTransformProvider.Configuration	build()
abstract AddFilesSchemaTransformProvider.Configuration.Builder	setCatalogProperties(Map<String,String> catalogProperties)
abstract AddFilesSchemaTransformProvider.Configuration.Builder	setConfigProperties(Map<String,String> confProperties)
abstract AddFilesSchemaTransformProvider.Configuration.Builder	setDryRun(Boolean dryRun)
abstract AddFilesSchemaTransformProvider.Configuration.Builder	setErrorHandling(ErrorHandling errorHandling)
abstract AddFilesSchemaTransformProvider.Configuration.Builder	setIncompatibleSchemaHandling(String handling)
abstract AddFilesSchemaTransformProvider.Configuration.Builder	setLocationPrefix(String prefix)
abstract AddFilesSchemaTransformProvider.Configuration.Builder	setManifestFileSize(Integer size)
abstract AddFilesSchemaTransformProvider.Configuration.Builder	setPartitionFields(List<String> fields)
abstract AddFilesSchemaTransformProvider.Configuration.Builder	setRequiredColumns(List<String> columns)
abstract AddFilesSchemaTransformProvider.Configuration.Builder	setSchemaEvolutionOptions(List<String> options)
abstract AddFilesSchemaTransformProvider.Configuration.Builder	setSortFields(List<String> sortFields)
abstract AddFilesSchemaTransformProvider.Configuration.Builder	setTable(String table)
abstract AddFilesSchemaTransformProvider.Configuration.Builder	setTableProperties(Map<String,String> props)
abstract AddFilesSchemaTransformProvider.Configuration.Builder	setTriggeringFrequencySeconds(Integer triggeringFrequencySeconds)
abstract AddFilesSchemaTransformProvider.Configuration.Builder	setUnverifiableFileHandling(String handling)

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 AddFilesSchemaTransformProvider.Configuration.Builder setTable(String table)

setCatalogProperties

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

setConfigProperties

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

setTriggeringFrequencySeconds

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

setManifestFileSize

public abstract AddFilesSchemaTransformProvider.Configuration.Builder setManifestFileSize(Integer size)

setLocationPrefix

public abstract AddFilesSchemaTransformProvider.Configuration.Builder setLocationPrefix(String prefix)

setPartitionFields

public abstract AddFilesSchemaTransformProvider.Configuration.Builder setPartitionFields(List<String> fields)

setTableProperties

public abstract AddFilesSchemaTransformProvider.Configuration.Builder setTableProperties(Map<String,String> props)

setSortFields

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

setErrorHandling

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

setSchemaEvolutionOptions

public abstract AddFilesSchemaTransformProvider.Configuration.Builder setSchemaEvolutionOptions(List<String> options)

setRequiredColumns

public abstract AddFilesSchemaTransformProvider.Configuration.Builder setRequiredColumns(List<String> columns)

setIncompatibleSchemaHandling

public abstract AddFilesSchemaTransformProvider.Configuration.Builder setIncompatibleSchemaHandling(String handling)

setUnverifiableFileHandling

public abstract AddFilesSchemaTransformProvider.Configuration.Builder setUnverifiableFileHandling(String handling)

setDryRun

public abstract AddFilesSchemaTransformProvider.Configuration.Builder setDryRun(Boolean dryRun)

build

public abstract AddFilesSchemaTransformProvider.Configuration build()