org.apache.flume.api

Class RpcClientConfigurationConstants

java.lang.Object

org.apache.flume.api.RpcClientConfigurationConstants

public final class RpcClientConfigurationConstants
extends Object

Configuration constants used by the RpcClient. These configuration keys can be specified via a Properties object to the appropriate method of RpcClientFactory in order to obtain a customized RPC client.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONFIG_BACKOFF
static String	CONFIG_BATCH_SIZE Configuration key used to specify the batch size.
static String	CONFIG_CLIENT_TYPE Configuration key to specify the RpcClient type to be used.
static String	CONFIG_COMPRESSION_LEVEL
static String	CONFIG_COMPRESSION_TYPE The following are const for the NettyAvro Client.
static String	CONFIG_CONNECT_TIMEOUT Configuration key to specify connection timeout in milliseconds.
static String	CONFIG_CONNECTION_POOL_SIZE Maximum number of connections each Thrift Rpc client can open to a given host.
static String	CONFIG_HOST_SELECTOR The selector type used by the LoadBalancingRpcClient.
static String	CONFIG_HOSTS Hosts configuration key to specify a space delimited list of named hosts.
static String	CONFIG_HOSTS_PREFIX Hosts prefix to specify address of a particular named host.
static String	CONFIG_MAX_ATTEMPTS Maximum attempts to be made by the FailoverRpcClient in case of failures.
static String	CONFIG_MAX_BACKOFF
static String	CONFIG_REQUEST_TIMEOUT Configuration key to specify request timeout in milliseconds.
static String	CONFIG_SSL Configuration constants for SSL support
static String	CONFIG_TRUST_ALL_CERTS
static String	CONFIG_TRUSTSTORE
static String	CONFIG_TRUSTSTORE_PASSWORD
static String	CONFIG_TRUSTSTORE_TYPE
static String	DEFAULT_BACKOFF
static Integer	DEFAULT_BATCH_SIZE Default batch size.
static String	DEFAULT_CLIENT_TYPE The default client type to be created if no explicit type is specified.
static int	DEFAULT_COMPRESSION_LEVEL
static long	DEFAULT_CONNECT_TIMEOUT_MILLIS Default connection, handshake, and initial request timeout in milliseconds.
static int	DEFAULT_CONNECTION_POOL_SIZE
static long	DEFAULT_REQUEST_TIMEOUT_MILLIS Default request timeout in milliseconds.
static String	HOST_SELECTOR_RANDOM
static String	HOST_SELECTOR_ROUND_ROBIN
static String	MAX_IO_WORKERS Configuration constants for the NettyAvroRpcClient NioClientSocketChannelFactory

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

CONFIG_HOSTS

public static final String CONFIG_HOSTS

Hosts configuration key to specify a space delimited list of named hosts. For example:

 hosts = h1 h2
 

See Also:

Constant Field Values

CONFIG_HOSTS_PREFIX

public static final String CONFIG_HOSTS_PREFIX

Hosts prefix to specify address of a particular named host. For example

 hosts.h1 = server1.example.com:12121
 hosts.h2 = server2.example.com:12121
 

See Also:

Constant Field Values

CONFIG_BATCH_SIZE

public static final String CONFIG_BATCH_SIZE

Configuration key used to specify the batch size. Default batch size is .

See Also:

Constant Field Values

CONFIG_CONNECT_TIMEOUT

public static final String CONFIG_CONNECT_TIMEOUT

Configuration key to specify connection timeout in milliseconds. The default connection timeout is .

See Also:

Constant Field Values

CONFIG_REQUEST_TIMEOUT

public static final String CONFIG_REQUEST_TIMEOUT

Configuration key to specify request timeout in milliseconds. The default request timeout is .

See Also:

Constant Field Values

DEFAULT_BATCH_SIZE

public static final Integer DEFAULT_BATCH_SIZE

Default batch size.

DEFAULT_CONNECT_TIMEOUT_MILLIS

public static final long DEFAULT_CONNECT_TIMEOUT_MILLIS

Default connection, handshake, and initial request timeout in milliseconds.

DEFAULT_REQUEST_TIMEOUT_MILLIS

public static final long DEFAULT_REQUEST_TIMEOUT_MILLIS

Default request timeout in milliseconds.

CONFIG_MAX_ATTEMPTS

public static final String CONFIG_MAX_ATTEMPTS

Maximum attempts to be made by the FailoverRpcClient in case of failures.

See Also:

Constant Field Values

CONFIG_CLIENT_TYPE

public static final String CONFIG_CLIENT_TYPE

Configuration key to specify the RpcClient type to be used. The available values are DEFAULT which results in the creation of a regular NettyAvroRpcClient and DEFAULT_FAILOVER which results in the creation of a failover client implementation on top of multiple NettyAvroRpcClients. The default value of this configuration is .

See Also:

Constant Field Values

DEFAULT_CLIENT_TYPE

public static final String DEFAULT_CLIENT_TYPE

The default client type to be created if no explicit type is specified.

CONFIG_HOST_SELECTOR

public static final String CONFIG_HOST_SELECTOR

The selector type used by the LoadBalancingRpcClient. This value of this setting could be either round_robin, random, or the fully qualified name class that implements the LoadBalancingRpcClient.HostSelector interface.

See Also:

Constant Field Values

HOST_SELECTOR_ROUND_ROBIN

public static final String HOST_SELECTOR_ROUND_ROBIN

See Also:

Constant Field Values

HOST_SELECTOR_RANDOM

public static final String HOST_SELECTOR_RANDOM

See Also:

Constant Field Values

CONFIG_MAX_BACKOFF

public static final String CONFIG_MAX_BACKOFF

See Also:

Constant Field Values

CONFIG_BACKOFF

public static final String CONFIG_BACKOFF

See Also:

Constant Field Values

DEFAULT_BACKOFF

public static final String DEFAULT_BACKOFF

See Also:

Constant Field Values

CONFIG_CONNECTION_POOL_SIZE

public static final String CONFIG_CONNECTION_POOL_SIZE

Maximum number of connections each Thrift Rpc client can open to a given host.

See Also:

Constant Field Values

DEFAULT_CONNECTION_POOL_SIZE

public static final int DEFAULT_CONNECTION_POOL_SIZE

See Also:

Constant Field Values

CONFIG_COMPRESSION_TYPE

public static final String CONFIG_COMPRESSION_TYPE

The following are const for the NettyAvro Client. To enable compression and set a compression level

See Also:

Constant Field Values

CONFIG_COMPRESSION_LEVEL

public static final String CONFIG_COMPRESSION_LEVEL

See Also:

Constant Field Values

DEFAULT_COMPRESSION_LEVEL

public static final int DEFAULT_COMPRESSION_LEVEL

See Also:

Constant Field Values

CONFIG_SSL

public static final String CONFIG_SSL

Configuration constants for SSL support

See Also:

Constant Field Values

CONFIG_TRUST_ALL_CERTS

public static final String CONFIG_TRUST_ALL_CERTS

See Also:

Constant Field Values

CONFIG_TRUSTSTORE

public static final String CONFIG_TRUSTSTORE

See Also:

Constant Field Values

CONFIG_TRUSTSTORE_PASSWORD

public static final String CONFIG_TRUSTSTORE_PASSWORD

See Also:

Constant Field Values

CONFIG_TRUSTSTORE_TYPE

public static final String CONFIG_TRUSTSTORE_TYPE

See Also:

Constant Field Values

MAX_IO_WORKERS

public static final String MAX_IO_WORKERS

Configuration constants for the NettyAvroRpcClient NioClientSocketChannelFactory

See Also:

Constant Field Values