org.apache.cassandra.service
Class StorageProxy

java.lang.Object
  extended by org.apache.cassandra.service.StorageProxy
All Implemented Interfaces:
StorageProxyMBean

public class StorageProxy
extends java.lang.Object
implements StorageProxyMBean


Method Summary
 double getRangeLatency()
           
 int getRangeOperations()
           
 double getReadLatency()
           
 int getReadOperations()
           
 double getWriteLatency()
           
 int getWriteOperations()
           
static void insert(RowMutation rm)
          Use this method to have this RowMutation applied across all replicas.
static void insertBlocking(RowMutation rm)
           
static void insertBlocking(RowMutation rm, int consistency_level)
           
static java.util.List<Row> readProtocol(java.util.List<ReadCommand> commands, int 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

insert

public static void insert(RowMutation rm)
Use this method to have this RowMutation 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.

Parameters:
rm - the mutation to be applied across the replicas

insertBlocking

public static void insertBlocking(RowMutation rm,
                                  int consistency_level)
                           throws org.apache.cassandra.service.UnavailableException
Throws:
org.apache.cassandra.service.UnavailableException

insertBlocking

public static void insertBlocking(RowMutation rm)
                           throws org.apache.cassandra.service.UnavailableException
Throws:
org.apache.cassandra.service.UnavailableException

readProtocol

public static java.util.List<Row> readProtocol(java.util.List<ReadCommand> commands,
                                               int consistency_level)
                                        throws java.io.IOException,
                                               java.util.concurrent.TimeoutException,
                                               org.apache.cassandra.service.InvalidRequestException,
                                               org.apache.cassandra.service.UnavailableException
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
java.util.concurrent.TimeoutException
org.apache.cassandra.service.InvalidRequestException
org.apache.cassandra.service.UnavailableException

getReadLatency

public double getReadLatency()
Specified by:
getReadLatency in interface StorageProxyMBean

getRangeLatency

public double getRangeLatency()
Specified by:
getRangeLatency in interface StorageProxyMBean

getWriteLatency

public double getWriteLatency()
Specified by:
getWriteLatency in interface StorageProxyMBean

getReadOperations

public int getReadOperations()
Specified by:
getReadOperations in interface StorageProxyMBean

getRangeOperations

public int getRangeOperations()
Specified by:
getRangeOperations in interface StorageProxyMBean

getWriteOperations

public int getWriteOperations()
Specified by:
getWriteOperations in interface StorageProxyMBean


Copyright © 2009 The Apache Software Foundation