me.prettyprint.cassandra.model
Class ExecutingKeyspace

java.lang.Object
  me.prettyprint.cassandra.model.ExecutingKeyspace

All Implemented Interfaces:

Keyspace

Direct Known Subclasses:

ExecutingVirtualKeyspace

public class ExecutingKeyspace
extends Object
implements Keyspace

Thread Safe

Author:

Ran Tavory, zznate

Field Summary

protected HConnectionManager	connectionManager
protected ConsistencyLevelPolicy	consistencyLevelPolicy
protected Map<String,String>	credentials
protected FailoverPolicy	failoverPolicy
protected String	keyspace

Fields inherited from interface me.prettyprint.hector.api.Keyspace

KEYSPACE_SYSTEM

Constructor Summary

ExecutingKeyspace(String keyspace, HConnectionManager connectionManager, ConsistencyLevelPolicy consistencyLevelPolicy, FailoverPolicy failoverPolicy)

ExecutingKeyspace(String keyspace, HConnectionManager connectionManager, ConsistencyLevelPolicy consistencyLevelPolicy, FailoverPolicy failoverPolicy, Map<String,String> credentials)

Method Summary

long	createClock()
<T> ExecutionResult<T>	doExecute(KeyspaceOperationCallback<T> koc)
<T> ExecutionResult<T>	doExecuteOperation(Operation<T> operation)
ExceptionsTranslator	getExceptionsTranslator()
String	getKeyspaceName()
void	setConsistencyLevelPolicy(ConsistencyLevelPolicy cp)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

consistencyLevelPolicy

protected ConsistencyLevelPolicy consistencyLevelPolicy

failoverPolicy

protected FailoverPolicy failoverPolicy

connectionManager

protected final HConnectionManager connectionManager

keyspace

protected final String keyspace

credentials

protected final Map<String,String> credentials

Constructor Detail

ExecutingKeyspace

public ExecutingKeyspace(String keyspace,
                         HConnectionManager connectionManager,
                         ConsistencyLevelPolicy consistencyLevelPolicy,
                         FailoverPolicy failoverPolicy)

ExecutingKeyspace

public ExecutingKeyspace(String keyspace,
                         HConnectionManager connectionManager,
                         ConsistencyLevelPolicy consistencyLevelPolicy,
                         FailoverPolicy failoverPolicy,
                         Map<String,String> credentials)

Method Detail

setConsistencyLevelPolicy

public void setConsistencyLevelPolicy(ConsistencyLevelPolicy cp)

Specified by:

setConsistencyLevelPolicy in interface Keyspace

getKeyspaceName

public String getKeyspaceName()

Specified by:

getKeyspaceName in interface Keyspace

toString

public String toString()

Overrides:

toString in class Object

createClock

public long createClock()

Specified by:

createClock in interface Keyspace

doExecute

public <T> ExecutionResult<T> doExecute(KeyspaceOperationCallback<T> koc)
                             throws HectorException

Throws:

HectorException

doExecuteOperation

public <T> ExecutionResult<T> doExecuteOperation(Operation<T> operation)
                                      throws HectorException

Throws:

HectorException

getExceptionsTranslator

public ExceptionsTranslator getExceptionsTranslator()