org.apache.beam.sdk.io.snowflake.services

Class SnowflakeServiceConfig

java.lang.Object

org.apache.beam.sdk.io.snowflake.services.ServiceConfig

org.apache.beam.sdk.io.snowflake.services.SnowflakeServiceConfig

public class SnowflakeServiceConfig
extends ServiceConfig

Constructor Summary

Constructors

Constructor and Description
SnowflakeServiceConfig(SerializableFunction<java.lang.Void,javax.sql.DataSource> dataSourceProviderFn, java.util.List<java.lang.String> filesList, java.lang.String table, java.lang.String query, WriteDisposition writeDisposition, java.lang.String storageIntegrationName, java.lang.String stagingBucketDir)
SnowflakeServiceConfig(SerializableFunction<java.lang.Void,javax.sql.DataSource> dataSourceProviderFn, java.lang.String table, java.lang.String query, java.lang.String storageIntegration, java.lang.String stagingBucketDir)

Method Summary

Modifier and Type	Method and Description
SerializableFunction<java.lang.Void,javax.sql.DataSource>	getDataSourceProviderFn()
java.util.List<java.lang.String>	getFilesList()
java.lang.String	getQuery()
java.lang.String	getStagingBucketDir()
java.lang.String	getstorageIntegrationName()
java.lang.String	getTable()
WriteDisposition	getWriteDisposition()

Methods inherited from class java.lang.Object

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

Constructor Detail

SnowflakeServiceConfig

public SnowflakeServiceConfig(SerializableFunction<java.lang.Void,javax.sql.DataSource> dataSourceProviderFn,
                              java.lang.String table,
                              java.lang.String query,
                              java.lang.String storageIntegration,
                              java.lang.String stagingBucketDir)

SnowflakeServiceConfig

public SnowflakeServiceConfig(SerializableFunction<java.lang.Void,javax.sql.DataSource> dataSourceProviderFn,
                              java.util.List<java.lang.String> filesList,
                              java.lang.String table,
                              java.lang.String query,
                              WriteDisposition writeDisposition,
                              java.lang.String storageIntegrationName,
                              java.lang.String stagingBucketDir)

Method Detail

getDataSourceProviderFn

public SerializableFunction<java.lang.Void,javax.sql.DataSource> getDataSourceProviderFn()

getTable

public java.lang.String getTable()

getQuery

public java.lang.String getQuery()

getstorageIntegrationName

public java.lang.String getstorageIntegrationName()

getStagingBucketDir

public java.lang.String getStagingBucketDir()

getFilesList

public java.util.List<java.lang.String> getFilesList()

getWriteDisposition

public WriteDisposition getWriteDisposition()