org.apache.beam.sdk.io.snowflake

Interface SnowflakePipelineOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

public interface SnowflakePipelineOptions
extends PipelineOptions

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.options.PipelineOptions

PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	AUTH_VALIDATION_GROUP
static java.lang.String	BASIC_CONNECTION_INFO_VALIDATION_GROUP

Method Summary

Modifier and Type	Method and Description
java.lang.String	getAuthenticator()
java.lang.String	getDatabase()
java.lang.String	getLoginTimeout()
java.lang.String	getOauthToken()
java.lang.String	getPassword()
java.lang.String	getPortNumber()
java.lang.String	getPrivateKeyPassphrase()
java.lang.String	getPrivateKeyPath()
java.lang.String	getRole()
java.lang.String	getSchema()
java.lang.String	getServerName()
java.lang.String	getStagingBucketName()
java.lang.String	getStorageIntegrationName()
java.lang.String	getUrl()
java.lang.String	getUsername()
java.lang.String	getWarehouse()
void	setAuthenticator(java.lang.String authenticator)
void	setDatabase(java.lang.String database)
void	setLoginTimeout(java.lang.String loginTimeout)
void	setOauthToken(java.lang.String oauthToken)
void	setPassword(java.lang.String password)
void	setPortNumber(java.lang.String portNumber)
void	setPrivateKeyPassphrase(java.lang.String keyPassphrase)
void	setPrivateKeyPath(java.lang.String privateKeyPath)
void	setRole(java.lang.String role)
void	setSchema(java.lang.String schema)
void	setServerName(java.lang.String serverName)
void	setStagingBucketName(java.lang.String stagingBucketName)
void	setStorageIntegrationName(java.lang.String storageIntegrationName)
void	setUrl(java.lang.String url)
void	setUsername(java.lang.String username)
void	setWarehouse(java.lang.String warehouse)

Methods inherited from interface org.apache.beam.sdk.options.PipelineOptions

as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

Methods inherited from interface org.apache.beam.sdk.transforms.display.HasDisplayData

populateDisplayData

Field Detail

BASIC_CONNECTION_INFO_VALIDATION_GROUP

static final java.lang.String BASIC_CONNECTION_INFO_VALIDATION_GROUP

See Also:

Constant Field Values

AUTH_VALIDATION_GROUP

static final java.lang.String AUTH_VALIDATION_GROUP

See Also:

Constant Field Values

Method Detail

getUrl

@Validation.Required(groups="BASIC_CONNECTION_INFO_GROUP")
java.lang.String getUrl()

setUrl

void setUrl(java.lang.String url)

getServerName

@Validation.Required(groups="BASIC_CONNECTION_INFO_GROUP")
java.lang.String getServerName()

setServerName

void setServerName(java.lang.String serverName)

getUsername

@Validation.Required(groups="AUTH_VALIDATION_GROUP")
java.lang.String getUsername()

setUsername

void setUsername(java.lang.String username)

getOauthToken

@Validation.Required(groups="AUTH_VALIDATION_GROUP")
java.lang.String getOauthToken()

setOauthToken

void setOauthToken(java.lang.String oauthToken)

getPassword

@Default.String(value="")
java.lang.String getPassword()

setPassword

void setPassword(java.lang.String password)

getPrivateKeyPath

@Default.String(value="")
java.lang.String getPrivateKeyPath()

setPrivateKeyPath

void setPrivateKeyPath(java.lang.String privateKeyPath)

getPrivateKeyPassphrase

@Default.String(value="")
java.lang.String getPrivateKeyPassphrase()

setPrivateKeyPassphrase

void setPrivateKeyPassphrase(java.lang.String keyPassphrase)

getWarehouse

@Default.String(value="")
java.lang.String getWarehouse()

setWarehouse

void setWarehouse(java.lang.String warehouse)

getDatabase

@Default.String(value="")
java.lang.String getDatabase()

setDatabase

void setDatabase(java.lang.String database)

getSchema

@Default.String(value="")
java.lang.String getSchema()

setSchema

void setSchema(java.lang.String schema)

getRole

@Default.String(value="")
java.lang.String getRole()

setRole

void setRole(java.lang.String role)

getAuthenticator

@Default.String(value="")
java.lang.String getAuthenticator()

setAuthenticator

void setAuthenticator(java.lang.String authenticator)

getPortNumber

@Default.String(value="")
java.lang.String getPortNumber()

setPortNumber

void setPortNumber(java.lang.String portNumber)

getLoginTimeout

@Default.String(value="")
java.lang.String getLoginTimeout()

setLoginTimeout

void setLoginTimeout(java.lang.String loginTimeout)

getStagingBucketName

java.lang.String getStagingBucketName()

setStagingBucketName

void setStagingBucketName(java.lang.String stagingBucketName)

getStorageIntegrationName

java.lang.String getStorageIntegrationName()

setStorageIntegrationName

void setStorageIntegrationName(java.lang.String storageIntegrationName)