@InterfaceAudience.Private public class HThreadedSelectorServerArgs extends org.apache.thrift.server.TThreadedSelectorServer.Args
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
|
Constructor and Description |
---|
HThreadedSelectorServerArgs(org.apache.thrift.transport.TNonblockingServerTransport transport,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
private void |
readConf(org.apache.hadoop.conf.Configuration conf) |
acceptPolicy, acceptQueueSizePerThread, executorService, getAcceptPolicy, getAcceptQueueSizePerThread, getExecutorService, getSelectorThreads, getStopTimeoutUnit, getStopTimeoutVal, getWorkerThreads, selectorThreads, stopTimeoutUnit, stopTimeoutVal, validate, workerThreads
private static final org.slf4j.Logger LOG
public static final String SELECTOR_THREADS_CONF_KEY
public static final String WORKER_THREADS_CONF_KEY
public static final String STOP_TIMEOUT_CONF_KEY
public static final String ACCEPT_QUEUE_SIZE_PER_THREAD_CONF_KEY
public static final String ACCEPT_POLICY_CONF_KEY
public HThreadedSelectorServerArgs(org.apache.thrift.transport.TNonblockingServerTransport transport, org.apache.hadoop.conf.Configuration conf)
private void readConf(org.apache.hadoop.conf.Configuration conf)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.