voldemort.store.stats
Class StreamingStats

java.lang.Object
  extended by voldemort.store.stats.StreamingStats

public class StreamingStats
extends java.lang.Object


Nested Class Summary
static class StreamingStats.Operation
           
 
Constructor Summary
StreamingStats()
           
StreamingStats(StreamingStats parent)
           
 
Method Summary
 double getAvgFetchEntriesNetworkTimeMs()
           
 double getAvgFetchEntriesStorageTimeMs()
           
 double getAvgFetchKeysNetworkTimeMs()
           
 double getAvgFetchKeysStorageTimeMs()
           
 double getAvgSlopUpdateNetworkTimeMs()
           
 double getAvgSlopUpdateStorageTimeMs()
           
 double getAvgUpdateEntriesNetworkTimeMs()
           
 double getAvgUpdateEntriesStorageTimeMs()
           
 double getFetchEntriesFetchRate()
           
 double getFetchEntriesScanRate()
           
 double getFetchFileFetchRate()
           
 double getFetchKeysFetchRate()
           
 double getFetchKeysScanRate()
           
 double getSlopUpdatePutRate()
           
 double getUpdateEntriesPutRate()
           
 void reportNetworkTime(StreamingStats.Operation op, long networkTimeMs)
           
 void reportStorageTime(StreamingStats.Operation op, long storageTimeMs)
           
 void reportStreamingFetch(StreamingStats.Operation op)
           
 void reportStreamingPut(StreamingStats.Operation op)
           
 void reportStreamingScan(StreamingStats.Operation op)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

StreamingStats

public StreamingStats()

StreamingStats

public StreamingStats(StreamingStats parent)
Method Detail

reportNetworkTime

public void reportNetworkTime(StreamingStats.Operation op,
                              long networkTimeMs)

reportStorageTime

public void reportStorageTime(StreamingStats.Operation op,
                              long storageTimeMs)

reportStreamingFetch

public void reportStreamingFetch(StreamingStats.Operation op)

reportStreamingScan

public void reportStreamingScan(StreamingStats.Operation op)

reportStreamingPut

public void reportStreamingPut(StreamingStats.Operation op)

getAvgFetchKeysNetworkTimeMs

public double getAvgFetchKeysNetworkTimeMs()

getAvgFetchKeysStorageTimeMs

public double getAvgFetchKeysStorageTimeMs()

getFetchKeysFetchRate

public double getFetchKeysFetchRate()

getFetchKeysScanRate

public double getFetchKeysScanRate()

getAvgFetchEntriesNetworkTimeMs

public double getAvgFetchEntriesNetworkTimeMs()

getAvgFetchEntriesStorageTimeMs

public double getAvgFetchEntriesStorageTimeMs()

getFetchEntriesFetchRate

public double getFetchEntriesFetchRate()

getFetchEntriesScanRate

public double getFetchEntriesScanRate()

getFetchFileFetchRate

public double getFetchFileFetchRate()

getAvgUpdateEntriesNetworkTimeMs

public double getAvgUpdateEntriesNetworkTimeMs()

getAvgUpdateEntriesStorageTimeMs

public double getAvgUpdateEntriesStorageTimeMs()

getUpdateEntriesPutRate

public double getUpdateEntriesPutRate()

getAvgSlopUpdateNetworkTimeMs

public double getAvgSlopUpdateNetworkTimeMs()

getAvgSlopUpdateStorageTimeMs

public double getAvgSlopUpdateStorageTimeMs()

getSlopUpdatePutRate

public double getSlopUpdatePutRate()


Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu