Package 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 Object
implements SnowflakeServices.BatchService

Implemenation of SnowflakeServices.BatchService used in production.

Constructor Summary

Constructors

Constructor	Description
SnowflakeBatchServiceImpl()

Method Summary

Modifier and Type	Method	Description
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 Details

SnowflakeBatchServiceImpl

public SnowflakeBatchServiceImpl()

Method Details

write

public void write(SnowflakeBatchServiceConfig config)
           throws Exception

Writing data to Snowflake in batch mode.

Specified by:

write in interface SnowflakeServices.BatchService

Throws:

Exception

read

public String read(SnowflakeBatchServiceConfig config)
            throws Exception

Reading data from Snowflake tables in batch processing.

Specified by:

read in interface SnowflakeServices.BatchService

Throws:

Exception