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

Class SnowflakeStreamingServiceImpl

java.lang.Object

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

All Implemented Interfaces:

SnowflakeServices.StreamingService

public class SnowflakeStreamingServiceImpl
extends Object
implements SnowflakeServices.StreamingService

Implementation of SnowflakeServices.StreamingService used in production.

Constructor Summary

Constructors

Constructor	Description
SnowflakeStreamingServiceImpl()

Method Summary

Modifier and Type	Method	Description
String	read(SnowflakeStreamingServiceConfig config)	Reading data from Snowflake in streaming mode is not supported.
void	write(SnowflakeStreamingServiceConfig config)	Writing data to Snowflake in streaming mode.

Methods inherited from class java.lang.Object

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

Constructor Details

SnowflakeStreamingServiceImpl

public SnowflakeStreamingServiceImpl()

Method Details

write

public void write(SnowflakeStreamingServiceConfig config)
           throws Exception

Writing data to Snowflake in streaming mode.

Specified by:

write in interface SnowflakeServices.StreamingService

Throws:

Exception

read

public String read(SnowflakeStreamingServiceConfig config)
            throws Exception

Reading data from Snowflake in streaming mode is not supported.

Specified by:

read in interface SnowflakeServices.StreamingService

Throws:

Exception