Package org.apache.beam.sdk.io.gcp.bigquery.providers

Class BigQueryWriteConfiguration.Builder

java.lang.Object

org.apache.beam.sdk.io.gcp.bigquery.providers.BigQueryWriteConfiguration.Builder

Enclosing class:

BigQueryWriteConfiguration

public abstract static class BigQueryWriteConfiguration.Builder
extends Object

Builder for BigQueryWriteConfiguration.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
abstract BigQueryWriteConfiguration	build()	Builds a BigQueryWriteConfiguration instance.
abstract BigQueryWriteConfiguration.Builder	setAutoSharding(Boolean autoSharding)
abstract BigQueryWriteConfiguration.Builder	setBigLakeConfiguration(Map<String,String> bigLakeConfiguration)
abstract BigQueryWriteConfiguration.Builder	setClusteringFields(List<String> clusteringFields)
abstract BigQueryWriteConfiguration.Builder	setCreateDisposition(String createDisposition)
abstract BigQueryWriteConfiguration.Builder	setDrop(List<String> drop)
abstract BigQueryWriteConfiguration.Builder	setErrorHandling(BigQueryWriteConfiguration.ErrorHandling errorHandling)
abstract BigQueryWriteConfiguration.Builder	setKeep(List<String> keep)
abstract BigQueryWriteConfiguration.Builder	setKmsKey(String kmsKey)
abstract BigQueryWriteConfiguration.Builder	setNumStreams(Integer numStreams)
abstract BigQueryWriteConfiguration.Builder	setOnly(String only)
abstract BigQueryWriteConfiguration.Builder	setPrimaryKey(List<String> pkColumns)
abstract BigQueryWriteConfiguration.Builder	setTable(String table)
abstract BigQueryWriteConfiguration.Builder	setTriggeringFrequencySeconds(Long seconds)
abstract BigQueryWriteConfiguration.Builder	setUseAtLeastOnceSemantics(Boolean use)
abstract BigQueryWriteConfiguration.Builder	setUseCdcWrites(Boolean cdcWrites)
abstract BigQueryWriteConfiguration.Builder	setWriteDisposition(String writeDisposition)

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

setCreateDisposition

public abstract BigQueryWriteConfiguration.Builder setCreateDisposition(String createDisposition)

setWriteDisposition

public abstract BigQueryWriteConfiguration.Builder setWriteDisposition(String writeDisposition)

setTriggeringFrequencySeconds

public abstract BigQueryWriteConfiguration.Builder setTriggeringFrequencySeconds(Long seconds)

setUseAtLeastOnceSemantics

public abstract BigQueryWriteConfiguration.Builder setUseAtLeastOnceSemantics(Boolean use)

setAutoSharding

public abstract BigQueryWriteConfiguration.Builder setAutoSharding(Boolean autoSharding)

setNumStreams

public abstract BigQueryWriteConfiguration.Builder setNumStreams(Integer numStreams)

setKmsKey

public abstract BigQueryWriteConfiguration.Builder setKmsKey(String kmsKey)

setErrorHandling

public abstract BigQueryWriteConfiguration.Builder setErrorHandling(BigQueryWriteConfiguration.ErrorHandling errorHandling)

setUseCdcWrites

public abstract BigQueryWriteConfiguration.Builder setUseCdcWrites(Boolean cdcWrites)

setPrimaryKey

public abstract BigQueryWriteConfiguration.Builder setPrimaryKey(List<String> pkColumns)

setKeep

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

setDrop

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

setOnly

public abstract BigQueryWriteConfiguration.Builder setOnly(String only)

setClusteringFields

public abstract BigQueryWriteConfiguration.Builder setClusteringFields(List<String> clusteringFields)

setBigLakeConfiguration

public abstract BigQueryWriteConfiguration.Builder setBigLakeConfiguration(Map<String,String> bigLakeConfiguration)

build

public abstract BigQueryWriteConfiguration build()

Builds a BigQueryWriteConfiguration instance.