com.impetus.kundera.client.cassandra.dsdriver

Class DSClientFactory

java.lang.Object

com.impetus.kundera.loader.GenericClientFactory

com.impetus.client.cassandra.common.CassandraClientFactory

com.impetus.kundera.client.cassandra.dsdriver.DSClientFactory

All Implemented Interfaces:

ClientFactory, ClientLifeCycleManager

public class DSClientFactory
extends CassandraClientFactory

Data stax java driver client factory.

Author:

vivek.mishra

Nested Class Summary

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

GenericClientFactory.LoadBalancer

Field Summary

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
DSClientFactory()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addCassandraHost(CassandraHost host)
protected Object	createPoolOrConnection()
void	destroy()
SchemaManager	getSchemaManager(Map<String,Object> puProperties)
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

Constructor Detail

DSClientFactory

public DSClientFactory()

Method Detail

getSchemaManager

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

destroy

public void destroy()

addCassandraHost

public boolean addCassandraHost(CassandraHost host)

Specified by:

addCassandraHost in class CassandraClientFactory

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