org.apache.cassandra.service
Class StorageProxy

java.lang.Object
  org.apache.cassandra.service.StorageProxy

All Implemented Interfaces:

StorageProxyMBean

public class StorageProxy
extends java.lang.Object
implements StorageProxyMBean

Method Summary

long	getRangeOperations()
static java.util.List<Row>	getRangeSlice(RangeSliceCommand command, org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
long	getReadOperations()
double	getRecentRangeLatencyMicros()
double	getRecentReadLatencyMicros()
double	getRecentWriteLatencyMicros()
long	getTotalRangeLatencyMicros()
long	getTotalReadLatencyMicros()
long	getTotalWriteLatencyMicros()
long	getWriteOperations()
static void	mutate(java.util.List<RowMutation> mutations) Use this method to have these RowMutations applied across all replicas.
static void	mutateBlocking(java.util.List<RowMutation> mutations, org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
static java.util.List<Row>	readProtocol(java.util.List<ReadCommand> commands, org.apache.cassandra.thrift.ConsistencyLevel consistency_level) Performs the actual reading of a row out of the StorageService, fetching a specific set of column names from a given column family.

Methods inherited from class java.lang.Object

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

Method Detail

mutate

public static void mutate(java.util.List<RowMutation> mutations)

Use this method to have these RowMutations applied across all replicas. This method will take care of the possibility of a replica being down and hint the data across to some other replica. This is the ZERO consistency level. We do not wait for replies.

Parameters:

mutations - the mutations to be applied across the replicas

mutateBlocking

public static void mutateBlocking(java.util.List<RowMutation> mutations,
                                  org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
                           throws org.apache.cassandra.thrift.UnavailableException,
                                  java.util.concurrent.TimeoutException

Throws:

org.apache.cassandra.thrift.UnavailableException

java.util.concurrent.TimeoutException

readProtocol

public static java.util.List<Row> readProtocol(java.util.List<ReadCommand> commands,
                                               org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
                                        throws java.io.IOException,
                                               org.apache.cassandra.thrift.UnavailableException,
                                               java.util.concurrent.TimeoutException

Performs the actual reading of a row out of the StorageService, fetching a specific set of column names from a given column family.

Throws:

java.io.IOException

org.apache.cassandra.thrift.UnavailableException

java.util.concurrent.TimeoutException

getRangeSlice

public static java.util.List<Row> getRangeSlice(RangeSliceCommand command,
                                                org.apache.cassandra.thrift.ConsistencyLevel consistency_level)
                                         throws java.io.IOException,
                                                org.apache.cassandra.thrift.UnavailableException,
                                                java.util.concurrent.TimeoutException

Throws:

java.io.IOException

org.apache.cassandra.thrift.UnavailableException

java.util.concurrent.TimeoutException

getReadOperations

public long getReadOperations()

Specified by:

getReadOperations in interface StorageProxyMBean

getTotalReadLatencyMicros

public long getTotalReadLatencyMicros()

Specified by:

getTotalReadLatencyMicros in interface StorageProxyMBean

getRecentReadLatencyMicros

public double getRecentReadLatencyMicros()

Specified by:

getRecentReadLatencyMicros in interface StorageProxyMBean

getRangeOperations

public long getRangeOperations()

Specified by:

getRangeOperations in interface StorageProxyMBean

getTotalRangeLatencyMicros

public long getTotalRangeLatencyMicros()

Specified by:

getTotalRangeLatencyMicros in interface StorageProxyMBean

getRecentRangeLatencyMicros

public double getRecentRangeLatencyMicros()

Specified by:

getRecentRangeLatencyMicros in interface StorageProxyMBean

getWriteOperations

public long getWriteOperations()

Specified by:

getWriteOperations in interface StorageProxyMBean

getTotalWriteLatencyMicros

public long getTotalWriteLatencyMicros()

Specified by:

getTotalWriteLatencyMicros in interface StorageProxyMBean

getRecentWriteLatencyMicros

public double getRecentWriteLatencyMicros()

Specified by:

getRecentWriteLatencyMicros in interface StorageProxyMBean