voldemort.store.stats
Class StreamingStats

java.lang.Object
  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	getSlopPusherScanRate()
double	getSlopUpdatePutRate()
double	getUpdateEntriesPutRate()
void	reportNetworkTime(StreamingStats.Operation op, long networkTimeNs)
void	reportStorageTime(StreamingStats.Operation op, long storageTimeNs)
void	reportStreamingFetch(StreamingStats.Operation op)
void	reportStreamingPut(StreamingStats.Operation op)
void	reportStreamingScan(StreamingStats.Operation op)
void	reportStreamingSlopScan()

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 networkTimeNs)

reportStorageTime

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

reportStreamingFetch

public void reportStreamingFetch(StreamingStats.Operation op)

reportStreamingScan

public void reportStreamingScan(StreamingStats.Operation op)

reportStreamingPut

public void reportStreamingPut(StreamingStats.Operation op)

reportStreamingSlopScan

public void reportStreamingSlopScan()

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()

getSlopPusherScanRate

public double getSlopPusherScanRate()