org.apache.hadoop.ipc.metrics

类 RpcInstrumentation

java.lang.Object

org.apache.hadoop.ipc.metrics.RpcInstrumentation

所有已实现的接口:

MetricsSource

public class RpcInstrumentation
extends Object
implements MetricsSource

The RPC metrics instrumentation

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	RpcInstrumentation.Detailed Use a separate source for detailed (per call) RPC metrics for easy and efficient filtering

方法概要

方法

限定符和类型	方法和说明
void	addRpcProcessingTime(int processingTime) Add an RPC processing time sample
void	addRpcProcessingTime(String methodName, int processingTime) Add an RPC processing time sample for a particular RPC method
void	addRpcQueueTime(int qTime) Add an RPC queue time sample
static RpcInstrumentation	create(String serverName, int port) Create an RPC instrumentation object
static RpcInstrumentation	create(String serverName, int port, MetricsSystem ms) Create an RPC instrumentation object Mostly useful for testing.
MetricsSource	detailed()
void	getMetrics(MetricsBuilder builder, boolean all) Get metrics from the source
void	incrAuthenticationFailures() One authentication failure event
void	incrAuthenticationSuccesses() One authentication success event
void	incrAuthorizationFailures() One authorization failure event
void	incrAuthorizationSuccesses() One authorization success event
void	incrReceivedBytes(int count) Increment received bytes by count
void	incrSentBytes(int count) Increment sent bytes by count
void	shutdown() Shutdown the instrumentation for the process

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

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

方法详细资料

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 RpcInstrumentation create(String serverName,
                        int port)

Create an RPC instrumentation object

参数:

serverName - name of the server

port - the RPC port

返回:

the instrumentation object

create

public static RpcInstrumentation create(String serverName,
                        int port,
                        MetricsSystem ms)

Create an RPC instrumentation object Mostly useful for testing.

参数:

serverName - name of the server

port - the RPC port

ms - the metrics system object

返回:

the instrumentation object

detailed

public MetricsSource detailed()

返回:

the detailed (per call) metrics source for RPC

incrAuthenticationFailures

public void incrAuthenticationFailures()

One authentication failure event

incrAuthenticationSuccesses

public void incrAuthenticationSuccesses()

One authentication success event

incrAuthorizationSuccesses

public void incrAuthorizationSuccesses()

One authorization success event

incrAuthorizationFailures

public void incrAuthorizationFailures()

One authorization failure event

shutdown

public void shutdown()

Shutdown the instrumentation for the process

incrSentBytes

public void incrSentBytes(int count)

Increment sent bytes by count

参数:

count - to increment

incrReceivedBytes

public void incrReceivedBytes(int count)

Increment received bytes by count

参数:

count - to increment

addRpcQueueTime

public void addRpcQueueTime(int qTime)

Add an RPC queue time sample

参数:

qTime -

addRpcProcessingTime

public void addRpcProcessingTime(int processingTime)

Add an RPC processing time sample

参数:

processingTime -

addRpcProcessingTime

public void addRpcProcessingTime(String methodName,
                        int processingTime)

Add an RPC processing time sample for a particular RPC method

参数:

methodName - method name of the RPC

processingTime - elapsed processing time of the RPC