Package com.snowflake.ingest.streaming

Class SnowflakeStreamingIngestClientFactory

java.lang.Object

com.snowflake.ingest.streaming.SnowflakeStreamingIngestClientFactory

public class SnowflakeStreamingIngestClientFactory
extends Object

Factory class used to build a SnowflakeStreamingIngestClient for a specific account/database/schema/pipe

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SnowflakeStreamingIngestClientFactory.Builder	Builder class to build a SnowflakeStreamingIngestClient

Constructor Summary

Constructors

Constructor	Description
SnowflakeStreamingIngestClientFactory()

Method Summary

Modifier and Type	Method	Description
static SnowflakeStreamingIngestClientFactory.Builder	builder(String clientName, String dbName, String schemaName, String pipeName)	Creates a new builder for a SnowflakeStreamingIngestClient for a specific account, database, schema, pipe with the provided name
static SnowflakeStreamingIngestClientFactory.Builder	tableBuilder(String clientName, String dbName, String schemaName, String tableName)	Creates a new builder for a table-mode SnowflakeStreamingIngestClient.

Methods inherited from class java.lang.Object

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

Constructor Details

SnowflakeStreamingIngestClientFactory

public SnowflakeStreamingIngestClientFactory()

Method Details

builder

public static SnowflakeStreamingIngestClientFactory.Builder builder(String clientName,
 String dbName,
 String schemaName,
 String pipeName)

Creates a new builder for a SnowflakeStreamingIngestClient for a specific account, database, schema, pipe with the provided name

Parameters:

clientName - the client name

dbName - the database name of the client

schemaName - the schema name of the client

pipeName - the pipe name of the client

Returns:

a new builder for a SnowflakeStreamingIngestClient to create the client

tableBuilder

public static SnowflakeStreamingIngestClientFactory.Builder tableBuilder(String clientName,
 String dbName,
 String schemaName,
 String tableName)

Creates a new builder for a table-mode SnowflakeStreamingIngestClient. The pipe name is derived from the table name by appending "-STREAMING".

Parameters:

clientName - the client name

dbName - the database name of the client

schemaName - the schema name of the client

tableName - the table name (pipe name will be tableName + "-STREAMING")

Returns:

a new builder for a table-mode SnowflakeStreamingIngestClient