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
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

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

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)