org.apache.accumulo.server.util
public class TServerUtils extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TServerUtils.ClientInfoProcessorFactory |
static class |
TServerUtils.ServerPort |
static class |
TServerUtils.THsHaServer |
static class |
TServerUtils.TimedProcessor |
Modifier and Type | Field and Description |
---|---|
static ThreadLocal<String> |
clientAddress |
Constructor and Description |
---|
TServerUtils() |
Modifier and Type | Method and Description |
---|---|
static TServerUtils.ServerPort |
startHsHaServer(int port,
org.apache.thrift.TProcessor processor,
String serverName,
String threadName,
int numThreads,
long timeBetweenThreadChecks,
long maxMessageSize) |
static TServerUtils.ServerPort |
startServer(AccumuloConfiguration conf,
Property portHintProperty,
org.apache.thrift.TProcessor processor,
String serverName,
String threadName,
Property portSearchProperty,
Property minThreadProperty,
Property timeBetweenThreadChecksProperty,
Property maxMessageSizeProperty)
Start a server, at the given port, or higher, if that port is not available.
|
static TServerUtils.ServerPort |
startThreadPoolServer(int port,
org.apache.thrift.TProcessor processor,
String serverName,
String threadName,
int numThreads) |
static TServerUtils.ServerPort |
startTServer(int port,
org.apache.thrift.TProcessor processor,
String serverName,
String threadName,
int numThreads,
long timeBetweenThreadChecks,
long maxMessageSize) |
static void |
stopTServer(org.apache.thrift.server.TServer s) |
public static final ThreadLocal<String> clientAddress
public static TServerUtils.ServerPort startServer(AccumuloConfiguration conf, Property portHintProperty, org.apache.thrift.TProcessor processor, String serverName, String threadName, Property portSearchProperty, Property minThreadProperty, Property timeBetweenThreadChecksProperty, Property maxMessageSizeProperty) throws UnknownHostException
portHintProperty
- the port to attempt to open, can be zero, meaning "any available port"processor
- the service to be startedserverName
- the name of the class that is providing the servicethreadName
- name this service's thread for better debuggingUnknownHostException
- when we don't know our own addresspublic static TServerUtils.ServerPort startHsHaServer(int port, org.apache.thrift.TProcessor processor, String serverName, String threadName, int numThreads, long timeBetweenThreadChecks, long maxMessageSize) throws org.apache.thrift.transport.TTransportException
org.apache.thrift.transport.TTransportException
public static TServerUtils.ServerPort startThreadPoolServer(int port, org.apache.thrift.TProcessor processor, String serverName, String threadName, int numThreads) throws org.apache.thrift.transport.TTransportException
org.apache.thrift.transport.TTransportException
public static TServerUtils.ServerPort startTServer(int port, org.apache.thrift.TProcessor processor, String serverName, String threadName, int numThreads, long timeBetweenThreadChecks, long maxMessageSize) throws org.apache.thrift.transport.TTransportException
org.apache.thrift.transport.TTransportException
public static void stopTServer(org.apache.thrift.server.TServer s)
Copyright © 2015 Apache Accumulo Project. All Rights Reserved.