Package org.apache.beam.sdk.io.jdbc

Class JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder

java.lang.Object

org.apache.beam.sdk.io.jdbc.JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder

Enclosing class:

JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration

public abstract static class JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration	build()
abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder	setConnectionInitSql(List<String> value)
abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder	setConnectionProperties(String value)
abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder	setDisableAutoCommit(Boolean value)
abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder	setDriverClassName(String value)
abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder	setDriverJars(String value)
abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder	setFetchSize(Integer value)
abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder	setJdbcType(String value)
abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder	setJdbcUrl(String value)
abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder	setLocation(String value)
abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder	setNumPartitions(Integer value)
abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder	setOutputParallelization(Boolean value)
abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder	setPartitionColumn(String value)
abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder	setPassword(String value)
abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder	setReadQuery(String value)
abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder	setUsername(String value)

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

setDriverClassName

public abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder setDriverClassName(String value)

setJdbcType

public abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder setJdbcType(String value)

setJdbcUrl

public abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder setJdbcUrl(String value)

setUsername

public abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder setUsername(String value)

setPassword

public abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder setPassword(String value)

setLocation

public abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder setLocation(String value)

setPartitionColumn

public abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder setPartitionColumn(String value)

setNumPartitions

public abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder setNumPartitions(Integer value)

setReadQuery

public abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder setReadQuery(String value)

setConnectionProperties

public abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder setConnectionProperties(String value)

setConnectionInitSql

public abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder setConnectionInitSql(List<String> value)

setFetchSize

public abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder setFetchSize(Integer value)

setOutputParallelization

public abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder setOutputParallelization(Boolean value)

setDisableAutoCommit

public abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder setDisableAutoCommit(Boolean value)

setDriverJars

public abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration.Builder setDriverJars(String value)

build

public abstract JdbcReadSchemaTransformProvider.JdbcReadSchemaTransformConfiguration build()