org.apache.hadoop.hdfs.server.datanode.metrics

类 DataNodeInstrumentation

java.lang.Object

org.apache.hadoop.hdfs.server.datanode.metrics.DataNodeInstrumentation

所有已实现的接口:

MetricsSource

public class DataNodeInstrumentation
extends Object
implements MetricsSource

构造器概要

构造器

构造器和说明
DataNodeInstrumentation(Configuration conf, String storageId)

方法概要

方法

限定符和类型	方法和说明
void	addBlockChecksumOp(long latency)
void	addBlockReport(long latency)
void	addCopyBlockOp(long latency)
void	addHeartBeat(long latency)
void	addReadBlockOp(long latency)
void	addReplaceBlockOp(long latency)
void	addWriteBlockOp(long latency)
static DataNodeInstrumentation	create(Configuration conf, String storageID)
static DataNodeInstrumentation	create(Configuration conf, String storageID, MetricsSystem ms)
void	getMetrics(MetricsBuilder builder, boolean all) Get metrics from the source
void	incrBlocksGetLocalPathInfo()
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	incrReadsFromLocalClient()
void	incrReadsFromRemoteClient()
void	incrWritesFromLocalClient()
void	incrWritesFromRemoteClient()
void	resetAllMinMax()
void	shutdown()

从类继承的方法 java.lang.Object

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

构造器详细资料

DataNodeInstrumentation

public DataNodeInstrumentation(Configuration conf,
                       String storageId)

方法详细资料

shutdown

public void shutdown()

resetAllMinMax

public void resetAllMinMax()

addHeartBeat

public void addHeartBeat(long latency)

addBlockReport

public void addBlockReport(long latency)

incrBlocksReplicated

public void incrBlocksReplicated(int delta)

incrBlocksWritten

public void incrBlocksWritten()

incrBlocksRemoved

public void incrBlocksRemoved(int delta)

incrBytesWritten

public void incrBytesWritten(int delta)

incrBlockVerificationFailures

public void incrBlockVerificationFailures()

incrBlocksVerified

public void incrBlocksVerified()

incrBlocksGetLocalPathInfo

public void incrBlocksGetLocalPathInfo()

addReadBlockOp

public void addReadBlockOp(long latency)

incrReadsFromLocalClient

public void incrReadsFromLocalClient()

incrReadsFromRemoteClient

public void incrReadsFromRemoteClient()

addWriteBlockOp

public void addWriteBlockOp(long latency)

incrWritesFromLocalClient

public void incrWritesFromLocalClient()

incrWritesFromRemoteClient

public void incrWritesFromRemoteClient()

addReplaceBlockOp

public void addReplaceBlockOp(long latency)

addCopyBlockOp

public void addCopyBlockOp(long latency)

addBlockChecksumOp

public void addBlockChecksumOp(long latency)

incrBytesRead

public void incrBytesRead(int delta)

incrBlocksRead

public void incrBlocksRead()

getMetrics

public void getMetrics(MetricsBuilder builder,
              boolean all)

从接口复制的说明: MetricsSource

Get metrics from the source

指定者:

getMetrics 在接口中 MetricsSource

参数:

builder - to contain the resulting metrics snapshot

all - if true, return all metrics even if unchanged.

create

public static DataNodeInstrumentation create(Configuration conf,
                             String storageID)

create

public static DataNodeInstrumentation create(Configuration conf,
                             String storageID,
                             MetricsSystem ms)