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

Interface SnowflakePipelineOptions

All Superinterfaces:

ApplicationNameOptions, HasDisplayData, PipelineOptions, StreamingOptions

public interface SnowflakePipelineOptions
extends PipelineOptions, StreamingOptions

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	Description
static final String	AUTH_VALIDATION_GROUP
static final String	BASIC_CONNECTION_INFO_VALIDATION_GROUP

Method Summary

Modifier and Type	Method	Description
String	getAuthenticator()
ValueProvider<String>	getDatabase()
String	getLoginTimeout()
String	getOauthToken()
ValueProvider<String>	getPassword()
String	getPortNumber()
ValueProvider<String>	getPrivateKeyPassphrase()
String	getPrivateKeyPath()
ValueProvider<String>	getQuery()
ValueProvider<String>	getRawPrivateKey()
ValueProvider<String>	getRole()
ValueProvider<String>	getSchema()
ValueProvider<String>	getServerName()
ValueProvider<String>	getSnowPipe()
ValueProvider<String>	getStagingBucketName()
ValueProvider<String>	getStorageIntegrationName()
ValueProvider<String>	getTable()
String	getUrl()
ValueProvider<String>	getUsername()
ValueProvider<String>	getWarehouse()
void	setAuthenticator(String authenticator)
void	setDatabase(ValueProvider<String> database)
void	setLoginTimeout(String loginTimeout)
void	setOauthToken(String oauthToken)
void	setPassword(ValueProvider<String> password)
void	setPortNumber(String portNumber)
void	setPrivateKeyPassphrase(ValueProvider<String> keyPassphrase)
void	setPrivateKeyPath(String privateKeyPath)
void	setQuery(ValueProvider<String> query)
void	setRawPrivateKey(ValueProvider<String> rawPrivateKey)
void	setRole(ValueProvider<String> role)
void	setSchema(ValueProvider<String> schema)
void	setServerName(ValueProvider<String> serverName)
void	setSnowPipe(ValueProvider<String> snowPipe)
void	setStagingBucketName(ValueProvider<String> stagingBucketName)
void	setStorageIntegrationName(ValueProvider<String> storageIntegrationName)
void	setTable(ValueProvider<String> table)
void	setUrl(String url)
void	setUsername(ValueProvider<String> username)
void	setWarehouse(ValueProvider<String> warehouse)

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

getAppName, setAppName

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

populateDisplayData

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

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

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

getUpdateCompatibilityVersion, isStreaming, setStreaming, setUpdateCompatibilityVersion

Field Details

BASIC_CONNECTION_INFO_VALIDATION_GROUP

static final String BASIC_CONNECTION_INFO_VALIDATION_GROUP

See Also:

• Constant Field Values

AUTH_VALIDATION_GROUP

static final String AUTH_VALIDATION_GROUP

See Also:

• Constant Field Values

Method Details

getUrl

@Required(groups="BASIC_CONNECTION_INFO_GROUP")
String getUrl()

setUrl

void setUrl(String url)

getServerName

@Required(groups="BASIC_CONNECTION_INFO_GROUP")
ValueProvider<String> getServerName()

setServerName

void setServerName(ValueProvider<String> serverName)

getUsername

@Required(groups="AUTH_VALIDATION_GROUP")
ValueProvider<String> getUsername()

setUsername

void setUsername(ValueProvider<String> username)

getOauthToken

@Required(groups="AUTH_VALIDATION_GROUP")
String getOauthToken()

setOauthToken

void setOauthToken(String oauthToken)

getPassword

@String("")
ValueProvider<String> getPassword()

setPassword

void setPassword(ValueProvider<String> password)

getPrivateKeyPath

@String("")
String getPrivateKeyPath()

setPrivateKeyPath

void setPrivateKeyPath(String privateKeyPath)

getRawPrivateKey

@String("")
ValueProvider<String> getRawPrivateKey()

setRawPrivateKey

void setRawPrivateKey(ValueProvider<String> rawPrivateKey)

getPrivateKeyPassphrase

@String("")
ValueProvider<String> getPrivateKeyPassphrase()

setPrivateKeyPassphrase

void setPrivateKeyPassphrase(ValueProvider<String> keyPassphrase)

getWarehouse

@String("")
ValueProvider<String> getWarehouse()

setWarehouse

void setWarehouse(ValueProvider<String> warehouse)

getDatabase

@String("")
@Required
ValueProvider<String> getDatabase()

setDatabase

void setDatabase(ValueProvider<String> database)

getSchema

@String("")
ValueProvider<String> getSchema()

setSchema

void setSchema(ValueProvider<String> schema)

getTable

@String("")
ValueProvider<String> getTable()

setTable

void setTable(ValueProvider<String> table)

getQuery

@String("")
ValueProvider<String> getQuery()

setQuery

void setQuery(ValueProvider<String> query)

getRole

@String("")
ValueProvider<String> getRole()

setRole

void setRole(ValueProvider<String> role)

getAuthenticator

@String("")
String getAuthenticator()

setAuthenticator

void setAuthenticator(String authenticator)

getPortNumber

@String("")
String getPortNumber()

setPortNumber

void setPortNumber(String portNumber)

getLoginTimeout

@String("")
String getLoginTimeout()

setLoginTimeout

void setLoginTimeout(String loginTimeout)

getStagingBucketName

@Required
ValueProvider<String> getStagingBucketName()

setStagingBucketName

void setStagingBucketName(ValueProvider<String> stagingBucketName)

getStorageIntegrationName

@Required
ValueProvider<String> getStorageIntegrationName()

setStorageIntegrationName

void setStorageIntegrationName(ValueProvider<String> storageIntegrationName)

getSnowPipe

ValueProvider<String> getSnowPipe()

setSnowPipe

void setSnowPipe(ValueProvider<String> snowPipe)