public class CassandraSessionPool extends BackendSessionPool
| Modifier and Type | Class and Description |
|---|---|
class |
CassandraSessionPool.Session
The Session class is a wrapper of driver Session
Expect every thread hold a its own session(wrapper)
|
| Constructor and Description |
|---|
CassandraSessionPool(String keyspace,
String store) |
| Modifier and Type | Method and Description |
|---|---|
void |
checkClusterConnected() |
void |
checkSessionConnected() |
com.datastax.driver.core.Cluster |
cluster() |
protected void |
doClose() |
protected CassandraSessionPool.Session |
newSession() |
void |
open(HugeConfig config) |
boolean |
opened() |
CassandraSessionPool.Session |
session() |
close, closed, closeSession, getOrNewSession, toString, useSessionpublic void open(HugeConfig config)
open in class BackendSessionPoolpublic final boolean opened()
opened in class BackendSessionPoolpublic final com.datastax.driver.core.Cluster cluster()
public final CassandraSessionPool.Session session()
session in class BackendSessionPoolprotected CassandraSessionPool.Session newSession()
newSession in class BackendSessionPoolprotected void doClose()
doClose in class BackendSessionPoolpublic final void checkClusterConnected()
public final void checkSessionConnected()
Copyright © 2017–2019. All rights reserved.