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

Class CrossLanguageConfiguration

java.lang.Object
org.apache.beam.sdk.io.snowflake.crosslanguage.CrossLanguageConfiguration
Direct Known Subclasses:
ReadBuilder.Configuration, WriteBuilder.Configuration
public abstract class CrossLanguageConfiguration extends Object
Parameters abstract class to expose the transforms to an external SDK.

  • Constructor Details

    • CrossLanguageConfiguration

      public CrossLanguageConfiguration()

  • Method Details

    • getServerName

      public String getServerName()

    • setServerName

      public void setServerName(String serverName)

    • getUsername

      public String getUsername()

    • setUsername

      public void setUsername(String username)

    • getPassword

      public String getPassword()

    • setPassword

      public void setPassword(String password)

    • getPrivateKeyPath

      public String getPrivateKeyPath()

    • setPrivateKeyPath

      public void setPrivateKeyPath(String privateKeyPath)

    • getRawPrivateKey

      public String getRawPrivateKey()

    • setRawPrivateKey

      public void setRawPrivateKey(String rawPrivateKey)

    • getPrivateKeyPassphrase

      public String getPrivateKeyPassphrase()

    • setPrivateKeyPassphrase

      public void setPrivateKeyPassphrase(String privateKeyPassphrase)

    • getOAuthToken

      public String getOAuthToken()

    • setOAuthToken

      public void setOAuthToken(String oAuthToken)

    • getDatabase

      public String getDatabase()

    • setDatabase

      public void setDatabase(String database)

    • getSchema

      public String getSchema()

    • setSchema

      public void setSchema(String schema)

    • getRole

      public String getRole()

    • setRole

      public void setRole(String role)

    • getWarehouse

      public String getWarehouse()

    • setWarehouse

      public void setWarehouse(String warehouse)

    • getTable

      public String getTable()

    • setTable

      public void setTable(String table)

    • getQuery

      public String getQuery()

    • setQuery

      public void setQuery(String query)

    • getStagingBucketName

      public String getStagingBucketName()

    • setStagingBucketName

      public void setStagingBucketName(String stagingBucketName)

    • getStorageIntegrationName

      public String getStorageIntegrationName()

    • setStorageIntegrationName

      public void setStorageIntegrationName(String storageIntegrationName)

    • getDataSourceConfiguration

      public SnowflakeIO.DataSourceConfiguration getDataSourceConfiguration()