org.apache.kudu.client

Class AsyncKuduClient.AsyncKuduClientBuilder

java.lang.Object

org.apache.kudu.client.AsyncKuduClient.AsyncKuduClientBuilder

Enclosing class:

AsyncKuduClient

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public static final class AsyncKuduClient.AsyncKuduClientBuilder
extends Object

Builder class to use in order to connect to Kudu. All the parameters beyond those in the constructors are optional.

Constructor Summary

Constructors

Constructor and Description
AsyncKuduClientBuilder(List<String> masterAddresses) Creates a new builder for a client that will connect to the specified masters.
AsyncKuduClientBuilder(String masterAddresses) Creates a new builder for a client that will connect to the specified masters.

Method Summary

Modifier and Type	Method and Description
AsyncKuduClient.AsyncKuduClientBuilder	bossCount(int bossCount) Set the maximum number of boss threads.
AsyncKuduClient	build() Creates a new client that connects to the masters.
AsyncKuduClient.AsyncKuduClientBuilder	defaultAdminOperationTimeoutMs(long timeoutMs) Sets the default timeout used for administrative operations (e.g.
AsyncKuduClient.AsyncKuduClientBuilder	defaultOperationTimeoutMs(long timeoutMs) Sets the default timeout used for user operations (using sessions and scanners).
AsyncKuduClient.AsyncKuduClientBuilder	defaultSocketReadTimeoutMs(long timeoutMs) Sets the default timeout to use when waiting on data from a socket.
AsyncKuduClient.AsyncKuduClientBuilder	disableStatistics() Disable this client's collection of statistics.
AsyncKuduClient.AsyncKuduClientBuilder	nioExecutors(Executor bossExecutor, Executor workerExecutor) Set the executors which will be used for the embedded Netty boss and workers.
AsyncKuduClient.AsyncKuduClientBuilder	workerCount(int workerCount) Set the maximum number of worker threads.

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncKuduClientBuilder

public AsyncKuduClientBuilder(String masterAddresses)

Creates a new builder for a client that will connect to the specified masters.

Parameters:

masterAddresses - comma-separated list of "host:port" pairs of the masters

AsyncKuduClientBuilder

public AsyncKuduClientBuilder(List<String> masterAddresses)

Creates a new builder for a client that will connect to the specified masters.

Here are some examples of recognized formats:

• example.com
• example.com:80
• 192.0.2.1
• 192.0.2.1:80
• [2001:db8::1]
• [2001:db8::1]:80
• 2001:db8::1

Parameters:

masterAddresses - list of master addresses

Method Detail

defaultAdminOperationTimeoutMs

public AsyncKuduClient.AsyncKuduClientBuilder defaultAdminOperationTimeoutMs(long timeoutMs)

Sets the default timeout used for administrative operations (e.g. createTable, deleteTable, etc). Optional. If not provided, defaults to 30s. A value of 0 disables the timeout.

Parameters:

timeoutMs - a timeout in milliseconds

Returns:

this builder

defaultOperationTimeoutMs

public AsyncKuduClient.AsyncKuduClientBuilder defaultOperationTimeoutMs(long timeoutMs)

Sets the default timeout used for user operations (using sessions and scanners). Optional. If not provided, defaults to 30s. A value of 0 disables the timeout.

Parameters:

timeoutMs - a timeout in milliseconds

Returns:

this builder

defaultSocketReadTimeoutMs

public AsyncKuduClient.AsyncKuduClientBuilder defaultSocketReadTimeoutMs(long timeoutMs)

Sets the default timeout to use when waiting on data from a socket. Optional. If not provided, defaults to 10s. A value of 0 disables the timeout.

Parameters:

timeoutMs - a timeout in milliseconds

Returns:

this builder

nioExecutors

public AsyncKuduClient.AsyncKuduClientBuilder nioExecutors(Executor bossExecutor,
                                                           Executor workerExecutor)

Set the executors which will be used for the embedded Netty boss and workers. Optional. If not provided, uses a simple cached threadpool. If either argument is null, then such a thread pool will be used in place of that argument. Note: executor's max thread number must be greater or equal to corresponding worker count, or netty cannot start enough threads, and client will get stuck. If not sure, please just use CachedThreadPool.

bossCount

public AsyncKuduClient.AsyncKuduClientBuilder bossCount(int bossCount)

Set the maximum number of boss threads. Optional. If not provided, 1 is used.

workerCount

public AsyncKuduClient.AsyncKuduClientBuilder workerCount(int workerCount)

Set the maximum number of worker threads. Optional. If not provided, (2 * the number of available processors) is used. If this client instance will be used on a machine running many client instances, it may be wise to lower this count, for example to avoid resource limits, at the possible cost of some performance of this client instance.

disableStatistics

public AsyncKuduClient.AsyncKuduClientBuilder disableStatistics()

Disable this client's collection of statistics. Statistics are enabled by default.

Returns:

this builder

build

public AsyncKuduClient build()

Creates a new client that connects to the masters. Doesn't block and won't throw an exception if the masters don't exist.

Returns:

a new asynchronous Kudu client