com.baidu.hugegraph.backend.store.cassandra

类 CassandraSessionPool

java.lang.Object

com.baidu.hugegraph.backend.store.BackendSessionPool

com.baidu.hugegraph.backend.store.cassandra.CassandraSessionPool

public class CassandraSessionPool
extends BackendSessionPool

嵌套类概要

嵌套类

限定符和类型	类和说明
class	CassandraSessionPool.Session The Session class is a wrapper of driver Session Expect every thread hold a its own session(wrapper)

构造器概要

构造器

构造器和说明
CassandraSessionPool(HugeConfig config, String keyspace, String store)

方法概要

限定符和类型	方法和说明
protected com.datastax.driver.core.Cluster	cluster()
boolean	clusterConnected()
protected void	doClose()
protected CassandraSessionPool.Session	newSession()
void	open()
boolean	opened()
CassandraSessionPool.Session	session()

从类继承的方法 com.baidu.hugegraph.backend.store.BackendSessionPool

close, closed, config, forceResetSessions, getOrNewSession, toString, useSession

从类继承的方法 java.lang.Object

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

构造器详细资料

CassandraSessionPool

public CassandraSessionPool(HugeConfig config,
                            String keyspace,
                            String store)

方法详细资料

open

public void open()

指定者:

open 在类中 BackendSessionPool

opened

public final boolean opened()

指定者:

opened 在类中 BackendSessionPool

cluster

protected final com.datastax.driver.core.Cluster cluster()

session

public final CassandraSessionPool.Session session()

指定者:

session 在类中 BackendSessionPool

newSession

protected CassandraSessionPool.Session newSession()

指定者:

newSession 在类中 BackendSessionPool

doClose

protected void doClose()

指定者:

doClose 在类中 BackendSessionPool

clusterConnected

public final boolean clusterConnected()