me.prettyprint.cassandra.service
Class VirtualKeyspaceOperation<T>

java.lang.Object
  me.prettyprint.cassandra.service.Operation<T>
      me.prettyprint.cassandra.service.VirtualKeyspaceOperation<T>

public class VirtualKeyspaceOperation<T>
extends Operation<T>

Field Summary

Fields inherited from class me.prettyprint.cassandra.service.Operation

consistencyLevelPolicy, credentials, execTime, failCounter, failoverPolicy, keyspaceName, operationType, result, stopWatchTagName

Constructor Summary

VirtualKeyspaceOperation(Operation<T> operation, ByteBuffer prefixBytes)

Method Summary

void	applyConnectionParams(String keyspace, ConsistencyLevelPolicy consistencyLevelPolicy, FailoverPolicy failoverPolicy, Map<String,String> credentials)
T	execute(org.apache.cassandra.thrift.Cassandra.Client cassandra) Performs the operation on the given cassandra instance.
void	executeAndSetResult(org.apache.cassandra.thrift.Cassandra.Client cassandra, CassandraHost cassandraHost)
CassandraHost	getCassandraHost()
HectorException	getException()
ExecutionResult<T>	getExecutionResult()
T	getResult()
boolean	hasException()
void	setException(HectorException e)
void	setResult(T executionResult)

Methods inherited from class java.lang.Object

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

Constructor Detail

VirtualKeyspaceOperation

public VirtualKeyspaceOperation(Operation<T> operation,
                                ByteBuffer prefixBytes)

Method Detail

applyConnectionParams

public void applyConnectionParams(String keyspace,
                                  ConsistencyLevelPolicy consistencyLevelPolicy,
                                  FailoverPolicy failoverPolicy,
                                  Map<String,String> credentials)

Overrides:

applyConnectionParams in class Operation<T>

setResult

public void setResult(T executionResult)

Overrides:

setResult in class Operation<T>

getResult

public T getResult()

Overrides:

getResult in class Operation<T>

Returns:

The result of the operation, if this is an operation that has a result (such as getColumn etc.

getExecutionResult

public ExecutionResult<T> getExecutionResult()

Overrides:

getExecutionResult in class Operation<T>

executeAndSetResult

public void executeAndSetResult(org.apache.cassandra.thrift.Cassandra.Client cassandra,
                                CassandraHost cassandraHost)
                         throws HectorException

Overrides:

executeAndSetResult in class Operation<T>

Throws:

HectorException

setException

public void setException(HectorException e)

Overrides:

setException in class Operation<T>

hasException

public boolean hasException()

Overrides:

hasException in class Operation<T>

getException

public HectorException getException()

Overrides:

getException in class Operation<T>

getCassandraHost

public CassandraHost getCassandraHost()

Overrides:

getCassandraHost in class Operation<T>

execute

public T execute(org.apache.cassandra.thrift.Cassandra.Client cassandra)
          throws HectorException

Description copied from class: Operation

Performs the operation on the given cassandra instance.

Specified by:

execute in class Operation<T>

Throws:

HectorException