org.apache.hadoop.hbase.thrift

Class HThreadedSelectorServerArgs

java.lang.Object

org.apache.thrift.server.TServer.AbstractServerArgs<T>

org.apache.thrift.server.AbstractNonblockingServer.AbstractNonblockingServerArgs<org.apache.thrift.server.TThreadedSelectorServer.Args>

org.apache.thrift.server.TThreadedSelectorServer.Args

org.apache.hadoop.hbase.thrift.HThreadedSelectorServerArgs

@InterfaceAudience.Private
public class HThreadedSelectorServerArgs
extends org.apache.thrift.server.TThreadedSelectorServer.Args

A TThreadedSelectorServer.Args that reads hadoop configuration

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.thrift.server.TThreadedSelectorServer.Args

org.apache.thrift.server.TThreadedSelectorServer.Args.AcceptPolicy

Field Summary

Fields

Modifier and Type	Field and Description
static String	ACCEPT_POLICY_CONF_KEY The strategy for handling new accepted connections.
static String	ACCEPT_QUEUE_SIZE_PER_THREAD_CONF_KEY Maximum number of accepted elements per selector
private static org.slf4j.Logger	LOG
static String	SELECTOR_THREADS_CONF_KEY Number of selector threads for reading and writing socket
static String	STOP_TIMEOUT_CONF_KEY Time to wait for server to stop gracefully
static String	WORKER_THREADS_CONF_KEY Number fo threads for processing the thrift calls

Fields inherited from class org.apache.thrift.server.TThreadedSelectorServer.Args

selectorThreads

Fields inherited from class org.apache.thrift.server.AbstractNonblockingServer.AbstractNonblockingServerArgs

maxReadBufferBytes

Constructor Summary

Constructors

Constructor and Description
HThreadedSelectorServerArgs(org.apache.thrift.transport.TNonblockingServerTransport transport, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
private void	readConf(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class org.apache.thrift.server.TThreadedSelectorServer.Args

acceptPolicy, acceptQueueSizePerThread, executorService, getAcceptPolicy, getAcceptQueueSizePerThread, getExecutorService, getSelectorThreads, getStopTimeoutUnit, getStopTimeoutVal, getWorkerThreads, selectorThreads, stopTimeoutUnit, stopTimeoutVal, validate, workerThreads

Methods inherited from class org.apache.thrift.server.TServer.AbstractServerArgs

inputProtocolFactory, inputTransportFactory, outputProtocolFactory, outputTransportFactory, processor, processorFactory, protocolFactory, transportFactory

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

SELECTOR_THREADS_CONF_KEY

public static final String SELECTOR_THREADS_CONF_KEY

Number of selector threads for reading and writing socket

See Also:

Constant Field Values

WORKER_THREADS_CONF_KEY

public static final String WORKER_THREADS_CONF_KEY

Number fo threads for processing the thrift calls

See Also:

Constant Field Values

STOP_TIMEOUT_CONF_KEY

public static final String STOP_TIMEOUT_CONF_KEY

Time to wait for server to stop gracefully

See Also:

Constant Field Values

ACCEPT_QUEUE_SIZE_PER_THREAD_CONF_KEY

public static final String ACCEPT_QUEUE_SIZE_PER_THREAD_CONF_KEY

Maximum number of accepted elements per selector

See Also:

Constant Field Values

ACCEPT_POLICY_CONF_KEY

public static final String ACCEPT_POLICY_CONF_KEY

The strategy for handling new accepted connections.

See Also:

Constant Field Values

Constructor Detail

HThreadedSelectorServerArgs

public HThreadedSelectorServerArgs(org.apache.thrift.transport.TNonblockingServerTransport transport,
                                   org.apache.hadoop.conf.Configuration conf)

Method Detail

readConf

private void readConf(org.apache.hadoop.conf.Configuration conf)