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

Class SnowflakeStreamingServiceImpl

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, SnowflakeService<SnowflakeStreamingServiceConfig>

public class SnowflakeStreamingServiceImpl
extends java.lang.Object
implements SnowflakeService<SnowflakeStreamingServiceConfig>

Implemenation of SnowflakeService used in production.

See Also:

Serialized Form

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 SnowflakeService<SnowflakeStreamingServiceConfig>

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 SnowflakeService<SnowflakeStreamingServiceConfig>

Throws:

java.lang.Exception