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 java.lang.Object
implements SnowflakeServices.StreamingService

Implementation of SnowflakeServices.StreamingService used in production.

Constructor Summary

Constructors

Constructor and Description
SnowflakeStreamingServiceImpl()

Method Summary

Modifier and Type	Method and Description
java.lang.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 Detail

SnowflakeStreamingServiceImpl

public SnowflakeStreamingServiceImpl()

Method Detail

write

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

Writing data to Snowflake in streaming mode.

Specified by:

write in interface SnowflakeServices.StreamingService

Throws:

java.lang.Exception

read

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

Reading data from Snowflake in streaming mode is not supported.

Specified by:

read in interface SnowflakeServices.StreamingService

Throws:

java.lang.Exception