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

Class SnowflakeBatchServiceImpl

java.lang.Object

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

All Implemented Interfaces:

SnowflakeServices.BatchService

public class SnowflakeBatchServiceImpl
extends java.lang.Object
implements SnowflakeServices.BatchService

Implemenation of SnowflakeServices.BatchService used in production.

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 SnowflakeServices.BatchService

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 SnowflakeServices.BatchService

Throws:

java.lang.Exception