org.apache.beam.sdk.io.jdbc

Class JdbcWriteSchemaTransformProvider.JdbcWriteSchemaTransformConfiguration

java.lang.Object

org.apache.beam.sdk.io.jdbc.JdbcWriteSchemaTransformProvider.JdbcWriteSchemaTransformConfiguration

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

JdbcWriteSchemaTransformProvider

@DefaultSchema(value=AutoValueSchema.class)
public abstract static class JdbcWriteSchemaTransformProvider.JdbcWriteSchemaTransformConfiguration
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JdbcWriteSchemaTransformProvider.JdbcWriteSchemaTransformConfiguration.Builder

Constructor Summary

Constructors

Constructor and Description
JdbcWriteSchemaTransformConfiguration()

Method Summary

Modifier and Type	Method and Description
static JdbcWriteSchemaTransformProvider.JdbcWriteSchemaTransformConfiguration.Builder	builder()
abstract java.lang.Boolean	getAutosharding()
abstract java.util.List<java.lang.String>	getConnectionInitSql()
abstract java.lang.String	getConnectionProperties()
abstract java.lang.String	getDriverClassName()
abstract java.lang.String	getJdbcUrl()
abstract java.lang.String	getLocation()
abstract java.lang.String	getPassword()
abstract java.lang.String	getUsername()
abstract java.lang.String	getWriteStatement()
void	validate()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JdbcWriteSchemaTransformConfiguration

public JdbcWriteSchemaTransformConfiguration()

Method Detail

getDriverClassName

public abstract java.lang.String getDriverClassName()

getJdbcUrl

public abstract java.lang.String getJdbcUrl()

getUsername

@Nullable
public abstract java.lang.String getUsername()

getPassword

@Nullable
public abstract java.lang.String getPassword()

getConnectionProperties

@Nullable
public abstract java.lang.String getConnectionProperties()

getConnectionInitSql

@Nullable
public abstract java.util.List<java.lang.String> getConnectionInitSql()

getLocation

@Nullable
public abstract java.lang.String getLocation()

getWriteStatement

@Nullable
public abstract java.lang.String getWriteStatement()

getAutosharding

@Nullable
public abstract java.lang.Boolean getAutosharding()

validate

public void validate()
              throws java.lang.IllegalArgumentException

Throws:

java.lang.IllegalArgumentException

builder

public static JdbcWriteSchemaTransformProvider.JdbcWriteSchemaTransformConfiguration.Builder builder()