voldemort.store.stats
Class StreamStats

java.lang.Object
  voldemort.store.stats.StreamStats

public class StreamStats
extends java.lang.Object

Nested Class Summary

static class	StreamStats.Handle
static class	StreamStats.Operation

Constructor Summary

StreamStats()

Method Summary

void	clearFinished()
void	closeHandle(StreamStats.Handle handle)
RequestCounter	getDiskCounter(StreamStats.Operation operation)
protected StreamStats.Handle	getHandle(long handleId)
java.util.Collection<java.lang.Long>	getHandleIds()
java.util.Collection<StreamStats.Handle>	getHandles()
RequestCounter	getNetworkCounter(StreamStats.Operation operation)
StreamStats.Handle	makeHandle(StreamStats.Operation operation, java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>> replicaToPartitionList)
void	recordDiskTime(StreamStats.Handle handle, long timeNs)
void	recordNetworkTime(StreamStats.Handle handle, long timeNs)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamStats

public StreamStats()

Method Detail

makeHandle

public StreamStats.Handle makeHandle(StreamStats.Operation operation,
                                     java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>> replicaToPartitionList)

closeHandle

public void closeHandle(StreamStats.Handle handle)

clearFinished

public void clearFinished()

getHandle

protected StreamStats.Handle getHandle(long handleId)

getHandleIds

public java.util.Collection<java.lang.Long> getHandleIds()

getHandles

public java.util.Collection<StreamStats.Handle> getHandles()

recordNetworkTime

public void recordNetworkTime(StreamStats.Handle handle,
                              long timeNs)

recordDiskTime

public void recordDiskTime(StreamStats.Handle handle,
                           long timeNs)

getNetworkCounter

public RequestCounter getNetworkCounter(StreamStats.Operation operation)

getDiskCounter

public RequestCounter getDiskCounter(StreamStats.Operation operation)