Package org.apache.hadoop.hbase.regionserver

Class MetricsUserSourceImpl

java.lang.Object

org.apache.hadoop.hbase.regionserver.MetricsUserSourceImpl

All Implemented Interfaces:

Comparable<MetricsUserSource>, MetricsUserSource

@Private
public class MetricsUserSourceImpl
extends Object
implements MetricsUserSource

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	MetricsUserSourceImpl.ClientMetricsImpl

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.regionserver.MetricsUserSource

MetricsUserSource.ClientMetrics

Field Summary

Fields

Modifier and Type	Field	Description
private MetricHistogram	appendHisto
private MutableFastCounter	blockBytesScannedCount
private ConcurrentHashMap<String,MetricsUserSource.ClientMetrics>	clientMetricsMap
private AtomicBoolean	closed
private MetricHistogram	deleteHisto
private MetricHistogram	getHisto
private final int	hashCode
private MetricHistogram	incrementHisto
private static final org.slf4j.Logger	LOG
private MetricHistogram	putHisto
private final DynamicMetricsRegistry	registry
private MetricHistogram	replayHisto
private MetricHistogram	scanTimeHisto
private final String	user
private final String	userAppendKey
private final String	userBlockBytesScannedKey
private final String	userDeleteKey
private final String	userGetKey
private final String	userIncrementKey
private final String	userNamePrefix
private final String	userPutKey
private final String	userReplayKey
private final String	userScanTimeKey

Constructor Summary

Constructors

Constructor	Description
MetricsUserSourceImpl(String user, MetricsUserAggregateSourceImpl agg)

Method Summary

Modifier and Type	Method	Description
int	compareTo(MetricsUserSource source)
void	deregister()
boolean	equals(Object obj)
Map<String,MetricsUserSource.ClientMetrics>	getClientMetrics()	Metrics collected at client level for a user(needed for reporting through clusterStatus and hbtop currently)
void	getMetrics(org.apache.hadoop.metrics2.MetricsCollector metricsCollector, boolean all)
MetricsUserSource.ClientMetrics	getOrCreateMetricsClient(String client)	Create a instance of ClientMetrics if not present otherwise return the previous one
String	getUser()
int	hashCode()
void	register()
(package private) void	snapshot(org.apache.hadoop.metrics2.MetricsRecordBuilder mrb, boolean ignored)
void	updateAppend(long time, long blockBytesScanned)
void	updateCheckAndMutate(long blockBytesScanned)
void	updateDelete(long t)
void	updateGet(long time, long blockBytesScanned)
void	updateIncrement(long time, long blockBytesScanned)
void	updatePut(long t)
void	updateReplay(long t)
void	updateScan(long time, long blockBytesScanned)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

userNamePrefix

private final String userNamePrefix

user

private final String user

userGetKey

private final String userGetKey

userScanTimeKey

private final String userScanTimeKey

userPutKey

private final String userPutKey

userDeleteKey

private final String userDeleteKey

userIncrementKey

private final String userIncrementKey

userAppendKey

private final String userAppendKey

userReplayKey

private final String userReplayKey

userBlockBytesScannedKey

private final String userBlockBytesScannedKey

getHisto

private MetricHistogram getHisto

scanTimeHisto

private MetricHistogram scanTimeHisto

putHisto

private MetricHistogram putHisto

deleteHisto

private MetricHistogram deleteHisto

incrementHisto

private MetricHistogram incrementHisto

appendHisto

private MetricHistogram appendHisto

replayHisto

private MetricHistogram replayHisto

blockBytesScannedCount

private MutableFastCounter blockBytesScannedCount

hashCode

private final int hashCode

closed

private AtomicBoolean closed

registry

private final DynamicMetricsRegistry registry

clientMetricsMap

private ConcurrentHashMap<String,MetricsUserSource.ClientMetrics> clientMetricsMap

Constructor Details

MetricsUserSourceImpl

public MetricsUserSourceImpl(String user,
 MetricsUserAggregateSourceImpl agg)

Method Details

register

public void register()

Specified by:

register in interface MetricsUserSource

deregister

public void deregister()

Specified by:

deregister in interface MetricsUserSource

getUser

public String getUser()

Specified by:

getUser in interface MetricsUserSource

compareTo

public int compareTo(MetricsUserSource source)

Specified by:

compareTo in interface Comparable<MetricsUserSource>

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

snapshot

void snapshot(org.apache.hadoop.metrics2.MetricsRecordBuilder mrb,
 boolean ignored)

updatePut

public void updatePut(long t)

Specified by:

updatePut in interface MetricsUserSource

updateDelete

public void updateDelete(long t)

Specified by:

updateDelete in interface MetricsUserSource

updateGet

public void updateGet(long time,
 long blockBytesScanned)

Specified by:

updateGet in interface MetricsUserSource

updateIncrement

public void updateIncrement(long time,
 long blockBytesScanned)

Specified by:

updateIncrement in interface MetricsUserSource

updateAppend

public void updateAppend(long time,
 long blockBytesScanned)

Specified by:

updateAppend in interface MetricsUserSource

updateReplay

public void updateReplay(long t)

Specified by:

updateReplay in interface MetricsUserSource

updateScan

public void updateScan(long time,
 long blockBytesScanned)

Specified by:

updateScan in interface MetricsUserSource

updateCheckAndMutate

public void updateCheckAndMutate(long blockBytesScanned)

Specified by:

updateCheckAndMutate in interface MetricsUserSource

getMetrics

public void getMetrics(org.apache.hadoop.metrics2.MetricsCollector metricsCollector,
 boolean all)

Specified by:

getMetrics in interface MetricsUserSource

getClientMetrics

public Map<String,MetricsUserSource.ClientMetrics> getClientMetrics()

Description copied from interface: MetricsUserSource

Metrics collected at client level for a user(needed for reporting through clusterStatus and hbtop currently)

Specified by:

getClientMetrics in interface MetricsUserSource

Returns:

metrics per hostname

getOrCreateMetricsClient

public MetricsUserSource.ClientMetrics getOrCreateMetricsClient(String client)

Description copied from interface: MetricsUserSource

Create a instance of ClientMetrics if not present otherwise return the previous one

Specified by:

getOrCreateMetricsClient in interface MetricsUserSource

Parameters:

client - hostname of the client

Returns:

Instance of ClientMetrics