@InterfaceAudience.Private @Metrics(about="DataNode metrics", context="dfs") public class DataNodeMetrics extends Object
This class has a number of metrics variables that are publicly accessible; these variables (objects) have methods to update their values; for example:
blocksRead
.inc()
Constructor and Description |
---|
DataNodeMetrics(String name,
String sessionId,
int[] intervals) |
Modifier and Type | Method and Description |
---|---|
void |
addBlockChecksumOp(long latency) |
void |
addBlockReport(long latency) |
void |
addCopyBlockOp(long latency) |
void |
addFlushNanos(long latencyNanos) |
void |
addFsyncNanos(long latencyNanos) |
void |
addHeartbeat(long latency) |
void |
addPacketAckRoundTripTimeNanos(long latencyNanos) |
void |
addReadBlockOp(long latency) |
void |
addReplaceBlockOp(long latency) |
void |
addSendDataPacketBlockedOnNetworkNanos(long latencyNanos) |
void |
addSendDataPacketTransferNanos(long latencyNanos) |
void |
addWriteBlockOp(long latency) |
static DataNodeMetrics |
create(Configuration conf,
String dnName) |
void |
incrBlocksGetLocalPathInfo()
Increment for getBlockLocalPathInfo calls
|
void |
incrBlocksRead() |
void |
incrBlocksRemoved(int delta) |
void |
incrBlocksReplicated(int delta) |
void |
incrBlocksVerified() |
void |
incrBlocksWritten() |
void |
incrBlockVerificationFailures() |
void |
incrBytesRead(int delta) |
void |
incrBytesWritten(int delta) |
void |
incrFsyncCount() |
void |
incrReadsFromClient(boolean local) |
void |
incrVolumeFailures() |
void |
incrWritesFromClient(boolean local) |
String |
name() |
void |
shutdown() |
public static DataNodeMetrics create(Configuration conf, String dnName)
public String name()
public void addHeartbeat(long latency)
public void addBlockReport(long latency)
public void incrBlocksReplicated(int delta)
public void incrBlocksWritten()
public void incrBlocksRemoved(int delta)
public void incrBytesWritten(int delta)
public void incrBlockVerificationFailures()
public void incrBlocksVerified()
public void addReadBlockOp(long latency)
public void addWriteBlockOp(long latency)
public void addReplaceBlockOp(long latency)
public void addCopyBlockOp(long latency)
public void addBlockChecksumOp(long latency)
public void incrBytesRead(int delta)
public void incrBlocksRead()
public void incrFsyncCount()
public void addPacketAckRoundTripTimeNanos(long latencyNanos)
public void addFlushNanos(long latencyNanos)
public void addFsyncNanos(long latencyNanos)
public void shutdown()
public void incrWritesFromClient(boolean local)
public void incrReadsFromClient(boolean local)
public void incrVolumeFailures()
public void incrBlocksGetLocalPathInfo()
public void addSendDataPacketBlockedOnNetworkNanos(long latencyNanos)
public void addSendDataPacketTransferNanos(long latencyNanos)
Copyright © 2013 Apache Software Foundation. All rights reserved.