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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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