org.apache.tephra.distributed

Class ThreadLocalClientProvider

java.lang.Object

org.apache.tephra.distributed.AbstractClientProvider

org.apache.tephra.distributed.ThreadLocalClientProvider

All Implemented Interfaces:

ThriftClientProvider

public class ThreadLocalClientProvider
extends AbstractClientProvider

An tx client provider that uses thread local to maintain at most one open connection per thread. Note that there can be a connection leak if the threads are recycled.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.tephra.distributed.AbstractClientProvider

AbstractClientProvider.EndpointStrategy, AbstractClientProvider.RandomEndpointStrategy, AbstractClientProvider.TimeLimitEndpointStrategy

Field Summary

Fields inherited from class org.apache.tephra.distributed.AbstractClientProvider

initialized

Constructor Summary

Constructors

Constructor and Description
ThreadLocalClientProvider(org.apache.hadoop.conf.Configuration conf, org.apache.twill.discovery.DiscoveryServiceClient discoveryServiceClient)

Method Summary

Methods

Modifier and Type	Method and Description
CloseableThriftClient	getCloseableClient() Retrieve an AutoCloseable wrapper around tx client for exclusive use by the current thread.
void	returnClient(TransactionServiceThriftClient client) Release an tx client back to the provider's pool, if the client is valid.
String	toString()

Methods inherited from class org.apache.tephra.distributed.AbstractClientProvider

initialize, newClient, newClient

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadLocalClientProvider

public ThreadLocalClientProvider(org.apache.hadoop.conf.Configuration conf,
                         org.apache.twill.discovery.DiscoveryServiceClient discoveryServiceClient)

Method Detail

getCloseableClient

public CloseableThriftClient getCloseableClient()
                                         throws org.apache.thrift.TException,
                                                TimeoutException,
                                                InterruptedException

Description copied from interface: ThriftClientProvider

Retrieve an AutoCloseable wrapper around tx client for exclusive use by the current thread. The client must be closed (returned) to the provider after use.

Returns:

an tx client, connected and fully functional

Throws:

org.apache.thrift.TException

TimeoutException

InterruptedException

returnClient

public void returnClient(TransactionServiceThriftClient client)

Description copied from interface: ThriftClientProvider

Release an tx client back to the provider's pool, if the client is valid. If the client becomes disfunctional, for instance, due to a socket exception. The provider must make sure to close the client, and it must remove the client from its arsenal and be prepared to create a new client subsequently.

Parameters:

client - The client to return

toString

public String toString()

Overrides:

toString in class Object