Package org.apache.beam.sdk.io.snowflake

Class SnowflakeReadSchemaTransformProvider.Configuration

java.lang.Object

org.apache.beam.sdk.io.snowflake.SnowflakeReadSchemaTransformProvider.Configuration

All Implemented Interfaces:

Serializable

Enclosing class:

SnowflakeReadSchemaTransformProvider

@DefaultSchema(AutoValueSchema.class)
public abstract static class SnowflakeReadSchemaTransformProvider.Configuration
extends Object
implements Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SnowflakeReadSchemaTransformProvider.Configuration.Builder

Constructor Summary

Constructors

Constructor	Description
Configuration()

Method Summary

Modifier and Type	Method	Description
static SnowflakeReadSchemaTransformProvider.Configuration.Builder	builder()
abstract String	getDatabase()
abstract String	getOauthToken()
abstract String	getPassword()
abstract String	getPrivateKey()
abstract String	getPrivateKeyPassphrase()
abstract String	getQuery()
abstract String	getQuotationMark()
abstract String	getRole()
abstract String	getSchema()
abstract String	getServerName()
abstract String	getSnowflakeSchema()
abstract String	getStagingBucketName()
abstract String	getStorageIntegrationName()
abstract String	getTable()
abstract String	getUsername()
abstract String	getWarehouse()
abstract SnowflakeReadSchemaTransformProvider.Configuration.Builder	toBuilder()

Methods inherited from class java.lang.Object

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

Constructor Details

Configuration

public Configuration()

Method Details

getServerName

@SchemaFieldDescription("Snowflake server name.")
public abstract String getServerName()

getUsername

@SchemaFieldDescription("Snowflake username. Required for password and private key authentication.")
@Nullable
public abstract String getUsername()

getPassword

@SchemaFieldDescription("Snowflake password. Mutually exclusive with OAuth token and private key.")
@Nullable
public abstract String getPassword()

getOauthToken

@SchemaFieldDescription("Snowflake OAuth token. Mutually exclusive with password and private key.")
@Nullable
public abstract String getOauthToken()

getPrivateKey

@SchemaFieldDescription("Raw Snowflake private key. Mutually exclusive with password and OAuth token.")
@Nullable
public abstract String getPrivateKey()

getPrivateKeyPassphrase

@SchemaFieldDescription("Passphrase for the Snowflake private key.")
@Nullable
public abstract String getPrivateKeyPassphrase()

getDatabase

@SchemaFieldDescription("Snowflake database name.")
public abstract String getDatabase()

getSnowflakeSchema

@SchemaFieldDescription("Snowflake schema name.")
public abstract String getSnowflakeSchema()

getWarehouse

@SchemaFieldDescription("Snowflake warehouse name.")
@Nullable
public abstract String getWarehouse()

getRole

@SchemaFieldDescription("Snowflake role.")
@Nullable
public abstract String getRole()

getTable

@SchemaFieldDescription("Snowflake table to read from.")
@Nullable
public abstract String getTable()

getQuery

@SchemaFieldDescription("Snowflake query to read from.")
@Nullable
public abstract String getQuery()

getStagingBucketName

@SchemaFieldDescription("GCS path used to stage CSV files. The path must end with \'/\'.")
public abstract String getStagingBucketName()

getStorageIntegrationName

@SchemaFieldDescription("Snowflake storage integration name.")
public abstract String getStorageIntegrationName()

getSchema

@SchemaFieldDescription("Output schema encoded using JSON Schema syntax.")
public abstract String getSchema()

getQuotationMark

@SchemaFieldDescription("Quotation mark used when parsing staged CSV files.")
@Nullable
public abstract String getQuotationMark()

builder

public static SnowflakeReadSchemaTransformProvider.Configuration.Builder builder()

toBuilder

public abstract SnowflakeReadSchemaTransformProvider.Configuration.Builder toBuilder()