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

Interface SnowflakeServices.StreamingService

All Known Implementing Classes:

SnowflakeStreamingServiceImpl

Enclosing interface:

SnowflakeServices

public static interface SnowflakeServices.StreamingService

Method Summary

Modifier and Type	Method and Description
java.lang.String	read(SnowflakeStreamingServiceConfig config)
void	write(SnowflakeStreamingServiceConfig config)

Method Detail

read

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

Throws:

java.lang.Exception

write

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

Throws:

java.lang.Exception