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

Class SnowflakeBatchServiceImpl

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, SnowflakeService<SnowflakeBatchServiceConfig>

public class SnowflakeBatchServiceImpl
extends java.lang.Object
implements SnowflakeService<SnowflakeBatchServiceConfig>

Implemenation of SnowflakeService used in production.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SnowflakeBatchServiceImpl()

Method Summary

Modifier and Type	Method and Description
java.lang.String	read(SnowflakeBatchServiceConfig config) Reading data from Snowflake tables in batch processing.
void	write(SnowflakeBatchServiceConfig config) Writing data to Snowflake in batch mode.

Methods inherited from class java.lang.Object

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

Constructor Detail

SnowflakeBatchServiceImpl

public SnowflakeBatchServiceImpl()

Method Detail

write

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

Writing data to Snowflake in batch mode.

Specified by:

write in interface SnowflakeService<SnowflakeBatchServiceConfig>

Throws:

java.lang.Exception

read

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

Reading data from Snowflake tables in batch processing.

Specified by:

read in interface SnowflakeService<SnowflakeBatchServiceConfig>

Throws:

java.lang.Exception