org.apache.tephra.distributed

Class SingleUseClientProvider

java.lang.Object

org.apache.tephra.distributed.AbstractClientProvider

org.apache.tephra.distributed.SingleUseClientProvider

All Implemented Interfaces:

ThriftClientProvider

public class SingleUseClientProvider
extends AbstractClientProvider

An tx client provider that creates a new connection every time.

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
SingleUseClientProvider(org.apache.hadoop.conf.Configuration conf, org.apache.twill.discovery.DiscoveryServiceClient discoveryServiceClient, int timeout)

Method Summary

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

SingleUseClientProvider

public SingleUseClientProvider(org.apache.hadoop.conf.Configuration conf,
                               org.apache.twill.discovery.DiscoveryServiceClient discoveryServiceClient,
                               int timeout)

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