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

Class SnowflakeServiceImpl

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, SnowflakeService<SnowflakeServiceConfig>

public class SnowflakeServiceImpl
extends java.lang.Object
implements SnowflakeService<SnowflakeServiceConfig>

Implemenation of SnowflakeService used in production.

See Also:

Serialized Form

Field Summary

Fields inherited from interface org.apache.beam.sdk.io.snowflake.services.SnowflakeService

CSV_QUOTE_CHAR_FOR_COPY

Constructor Summary

Constructors

Constructor and Description
SnowflakeServiceImpl()

Method Summary

Modifier and Type	Method and Description
java.lang.String	copyIntoStage(SnowflakeServiceConfig config)
void	copyToTable(SnowflakeServiceConfig config)
java.lang.String	read(SnowflakeServiceConfig config)
void	write(SnowflakeServiceConfig config)

Methods inherited from class java.lang.Object

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

Constructor Detail

SnowflakeServiceImpl

public SnowflakeServiceImpl()

Method Detail

write

public void write(SnowflakeServiceConfig config)
           throws java.lang.Exception

Specified by:

write in interface SnowflakeService<SnowflakeServiceConfig>

Throws:

java.lang.Exception

read

public java.lang.String read(SnowflakeServiceConfig config)
                      throws java.lang.Exception

Specified by:

read in interface SnowflakeService<SnowflakeServiceConfig>

Throws:

java.lang.Exception

copyIntoStage

public java.lang.String copyIntoStage(SnowflakeServiceConfig config)
                               throws java.sql.SQLException

Throws:

java.sql.SQLException

copyToTable

public void copyToTable(SnowflakeServiceConfig config)
                 throws java.sql.SQLException

Throws:

java.sql.SQLException