org.apache.tephra.distributed

Class PooledClientProvider

java.lang.Object

org.apache.tephra.distributed.AbstractClientProvider

org.apache.tephra.distributed.PooledClientProvider

All Implemented Interfaces:

ThriftClientProvider

public class PooledClientProvider
extends AbstractClientProvider

This is an tx client provider that uses a bounded size pool of connections.

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

PooledClientProvider

public PooledClientProvider(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