Package org.apache.accumulo.core.clientImpl

Class ThriftTransportPool

java.lang.Object

org.apache.accumulo.core.clientImpl.ThriftTransportPool

public class ThriftTransportPool
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ThriftTransportPool.TransportPoolShutdownException

Method Summary

Modifier and Type	Method	Description
Pair<String,org.apache.thrift.transport.TTransport>	getAnyTransport(List<ThriftTransportKey> servers, boolean preferCachedConnection)
static ThriftTransportPool	getInstance()
org.apache.thrift.transport.TTransport	getTransport(HostAndPort location, long milliseconds, ClientContext context)
void	returnTransport(org.apache.thrift.transport.TTransport transport)
void	setIdleTime(long time)	Set the time after which idle connections should be closed
void	startCheckerThread()

Methods inherited from class java.lang.Object

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

Method Detail

getTransport

public org.apache.thrift.transport.TTransport getTransport(HostAndPort location,
                                                           long milliseconds,
                                                           ClientContext context)
                                                    throws org.apache.thrift.transport.TTransportException

Throws:

org.apache.thrift.transport.TTransportException

getAnyTransport

public Pair<String,org.apache.thrift.transport.TTransport> getAnyTransport(List<ThriftTransportKey> servers,
                                                                                 boolean preferCachedConnection)
                                                                          throws org.apache.thrift.transport.TTransportException

Throws:

org.apache.thrift.transport.TTransportException

returnTransport

public void returnTransport(org.apache.thrift.transport.TTransport transport)

setIdleTime

public void setIdleTime(long time)

Set the time after which idle connections should be closed

getInstance

public static ThriftTransportPool getInstance()

startCheckerThread

public void startCheckerThread()