Package com.snowflake.ingest.streaming

Class SnowflakeStreamingIngestClientFactory.Builder

java.lang.Object

com.snowflake.ingest.streaming.SnowflakeStreamingIngestClientFactory.Builder

Enclosing class:

SnowflakeStreamingIngestClientFactory

public static class SnowflakeStreamingIngestClientFactory.Builder
extends java.lang.Object

Builder class to build a SnowflakeStreamingIngestClient

Method Summary

Modifier and Type	Method	Description
SnowflakeStreamingIngestClient	build()	Builds a SnowflakeStreamingIngestClient with the provided parameters
SnowflakeStreamingIngestClientFactory.Builder	setExecutorService(java.util.concurrent.ExecutorService executorService)	Set an optional ExecutorService for asynchronous operations.
SnowflakeStreamingIngestClientFactory.Builder	setParameterOverrides(java.util.Map<java.lang.String,java.lang.Object> parameterOverrides)	Set the parameter overrides for the client
SnowflakeStreamingIngestClientFactory.Builder	setProperties(java.util.Properties prop)	Set the properties for the client

Methods inherited from class java.lang.Object

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

Method Detail

setProperties

public SnowflakeStreamingIngestClientFactory.Builder setProperties(java.util.Properties prop)

Set the properties for the client

Parameters:

prop - the properties

Returns:

the builder

setParameterOverrides

public SnowflakeStreamingIngestClientFactory.Builder setParameterOverrides(java.util.Map<java.lang.String,java.lang.Object> parameterOverrides)

Set the parameter overrides for the client

Parameters:

parameterOverrides - the parameter overrides

Returns:

the builder

setExecutorService

public SnowflakeStreamingIngestClientFactory.Builder setExecutorService(java.util.concurrent.ExecutorService executorService)

Set an optional ExecutorService for asynchronous operations.

If not provided, the client will create and manage its own ExecutorService internally. The provided executor will be used for operations like waitForCommit that require background task execution.

Important: If you provide your own executor, you are responsible for shutting it down. The client will not automatically shut down user-provided executors when close() is called.

Parameters:

executorService - the ExecutorService to use for async operations

Returns:

the builder

build

public SnowflakeStreamingIngestClient build()

Builds a SnowflakeStreamingIngestClient with the provided parameters

Returns:

a new SnowflakeStreamingIngestClient