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


Field Summary
static java.util.Comparator<java.lang.String> keyComparator
           
 
Method Summary
 boolean getHintedHandoffEnabled()
           
 long getRangeOperations()
           
static java.util.List<Row> getRangeSlice(RangeSliceCommand command, ConsistencyLevel consistency_level)
           
 long getReadOperations()
           
 double getRecentRangeLatencyMicros()
           
 double getRecentReadLatencyMicros()
           
 double getRecentWriteLatencyMicros()
           
 long getTotalRangeLatencyMicros()
           
 long getTotalReadLatencyMicros()
           
 long getTotalWriteLatencyMicros()
           
 long getWriteOperations()
           
static boolean isHintedHandoffEnabled()
           
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, ConsistencyLevel consistency_level)
           
static java.util.List<Row> readProtocol(java.util.List<ReadCommand> commands, 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.
 void setHintedHandoffEnabled(boolean b)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

keyComparator

public static final java.util.Comparator<java.lang.String> keyComparator
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,
                                  ConsistencyLevel consistency_level)
                           throws UnavailableException,
                                  java.util.concurrent.TimeoutException
Throws:
UnavailableException
java.util.concurrent.TimeoutException

readProtocol

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

getRangeSlice

public static java.util.List<Row> getRangeSlice(RangeSliceCommand command,
                                                ConsistencyLevel consistency_level)
                                         throws java.io.IOException,
                                                UnavailableException,
                                                java.util.concurrent.TimeoutException
Throws:
java.io.IOException
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

getHintedHandoffEnabled

public boolean getHintedHandoffEnabled()
Specified by:
getHintedHandoffEnabled in interface StorageProxyMBean

setHintedHandoffEnabled

public void setHintedHandoffEnabled(boolean b)
Specified by:
setHintedHandoffEnabled in interface StorageProxyMBean

isHintedHandoffEnabled

public static boolean isHintedHandoffEnabled()


Copyright © 2010 The Apache Software Foundation