com.impetus.client.cassandra.thrift

Class ThriftClientFactory

java.lang.Object

com.impetus.kundera.loader.GenericClientFactory

com.impetus.client.cassandra.common.CassandraClientFactory

com.impetus.client.cassandra.thrift.ThriftClientFactory

All Implemented Interfaces:

ClientFactory, ClientLifeCycleManager

public class ThriftClientFactory
extends CassandraClientFactory

A factory of ThriftClient Currently it uses Pelops for Connection pooling. Need to replace it with our own pooling. Most of the code is borrowed from PelopsClientFactory

Author:

amresh.singh

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ThriftClientFactory.Connection Connection class holds client and related pool.

Nested classes/interfaces inherited from class com.impetus.kundera.loader.GenericClientFactory

GenericClientFactory.LoadBalancer

Field Summary

Fields

Modifier and Type	Field and Description
protected HostConfiguration	configuration The configuration.

Fields inherited from class com.impetus.client.cassandra.common.CassandraClientFactory

timestampGenerator

Fields inherited from class com.impetus.kundera.loader.GenericClientFactory

clientMetadata, externalProperties, hostPools, hostRetryService, indexManager, kunderaMetadata, loadBalancingPolicy, propertyReader, reader, schemaManager

Constructor Summary

Constructors

Constructor and Description
ThriftClientFactory()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addCassandraHost(CassandraHost cassandraHost) Adds a pool in hostPools map for given host.
protected Object	createPoolOrConnection()
void	destroy()
SchemaManager	getSchemaManager(Map<String,Object> externalProperty)
void	initialize(Map<String,Object> externalProperty)
protected void	initializeLoadBalancer(String loadBalancingPolicyName)
protected Client	instantiateClient(String persistenceUnit)
boolean	isThreadSafe()

Methods inherited from class com.impetus.client.cassandra.common.CassandraClientFactory

initializeTimestampGenerator

Methods inherited from class com.impetus.kundera.loader.GenericClientFactory

getClientInstance, getClientMetadata, getConnectionPoolOrConnection, getPersistenceUnit, load, loadClientMetadata, onValidation, setConnectionPoolOrConnection, setExternalProperties, setKunderaMetadata, unload

Methods inherited from class java.lang.Object

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

Field Detail

configuration

protected HostConfiguration configuration

The configuration.

Constructor Detail

ThriftClientFactory

public ThriftClientFactory()

Method Detail

getSchemaManager

public SchemaManager getSchemaManager(Map<String,Object> externalProperty)

destroy

public void destroy()

initialize

public void initialize(Map<String,Object> externalProperty)

Specified by:

initialize in interface ClientLifeCycleManager

Specified by:

initialize in class GenericClientFactory

createPoolOrConnection

protected Object createPoolOrConnection()

Specified by:

createPoolOrConnection in class GenericClientFactory

instantiateClient

protected Client instantiateClient(String persistenceUnit)

Specified by:

instantiateClient in class GenericClientFactory

isThreadSafe

public boolean isThreadSafe()

Specified by:

isThreadSafe in interface ClientLifeCycleManager

Specified by:

isThreadSafe in class GenericClientFactory

initializeLoadBalancer

protected void initializeLoadBalancer(String loadBalancingPolicyName)

Specified by:

initializeLoadBalancer in class GenericClientFactory

addCassandraHost

public boolean addCassandraHost(CassandraHost cassandraHost)

Adds a pool in hostPools map for given host.

Specified by:

addCassandraHost in class CassandraClientFactory

Parameters:

cassandraHost - the cassandra host

Returns:

true id added successfully.