Package org.apache.hadoop.hbase.regionserver

Class MetricsUserAggregateImpl

java.lang.Object

org.apache.hadoop.hbase.regionserver.MetricsUserAggregateImpl

All Implemented Interfaces:

MetricsUserAggregate

@Private
public class MetricsUserAggregateImpl
extends Object
implements MetricsUserAggregate

Field Summary

Fields

Modifier and Type	Field	Description
private final MetricsUserAggregateSource	source
private final LossyCounting<MetricsUserSource>	userMetricLossyCounting
private final UserProvider	userProvider	Provider for mapping principal names to Users

Constructor Summary

Constructors

Constructor	Description
MetricsUserAggregateImpl(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
private String	getActiveUser()	Returns the active user to which authorization checks should be applied.
private String	getClient()
private MetricsUserSource	getOrCreateMetricsUser(String user)
MetricsUserAggregateSource	getSource()	Returns return a singleton instance of MetricsUserAggregateSource or null in case of NoOp
private void	incrementClientReadMetrics(MetricsUserSource userSource)
private void	incrementClientWriteMetrics(MetricsUserSource userSource)
private void	incrementFilteredReadRequests(MetricsUserSource userSource)
void	updateAppend(long time, long blockBytesScanned)
void	updateCheckAndMutate(long blockBytesScanned)
void	updateDelete(long t)
void	updateFilteredReadRequests()
void	updateGet(long time, long blockBytesScanned)
void	updateIncrement(long time, long blockBytesScanned)
void	updatePut(long t)
void	updateReadRequestCount()
void	updateReplay(long t)
void	updateScan(long time, long blockBytesScanned)

Methods inherited from class java.lang.Object

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

Field Details

userProvider

private final UserProvider userProvider

Provider for mapping principal names to Users

source

private final MetricsUserAggregateSource source

userMetricLossyCounting

private final LossyCounting<MetricsUserSource> userMetricLossyCounting

Constructor Details

MetricsUserAggregateImpl

public MetricsUserAggregateImpl(org.apache.hadoop.conf.Configuration conf)

Method Details

getActiveUser

private String getActiveUser()

Returns the active user to which authorization checks should be applied. If we are in the context of an RPC call, the remote user is used, otherwise the currently logged in user is used.

getSource

public MetricsUserAggregateSource getSource()

Description copied from interface: MetricsUserAggregate

Returns return a singleton instance of MetricsUserAggregateSource or null in case of NoOp

Specified by:

getSource in interface MetricsUserAggregate

updatePut

public void updatePut(long t)

Specified by:

updatePut in interface MetricsUserAggregate

getClient

private String getClient()

incrementClientReadMetrics

private void incrementClientReadMetrics(MetricsUserSource userSource)

incrementFilteredReadRequests

private void incrementFilteredReadRequests(MetricsUserSource userSource)

incrementClientWriteMetrics

private void incrementClientWriteMetrics(MetricsUserSource userSource)

updateDelete

public void updateDelete(long t)

Specified by:

updateDelete in interface MetricsUserAggregate

updateGet

public void updateGet(long time,
 long blockBytesScanned)

Specified by:

updateGet in interface MetricsUserAggregate

updateIncrement

public void updateIncrement(long time,
 long blockBytesScanned)

Specified by:

updateIncrement in interface MetricsUserAggregate

updateAppend

public void updateAppend(long time,
 long blockBytesScanned)

Specified by:

updateAppend in interface MetricsUserAggregate

updateReplay

public void updateReplay(long t)

Specified by:

updateReplay in interface MetricsUserAggregate

updateScan

public void updateScan(long time,
 long blockBytesScanned)

Specified by:

updateScan in interface MetricsUserAggregate

updateCheckAndMutate

public void updateCheckAndMutate(long blockBytesScanned)

Specified by:

updateCheckAndMutate in interface MetricsUserAggregate

updateFilteredReadRequests

public void updateFilteredReadRequests()

Specified by:

updateFilteredReadRequests in interface MetricsUserAggregate

updateReadRequestCount

public void updateReadRequestCount()

Specified by:

updateReadRequestCount in interface MetricsUserAggregate

getOrCreateMetricsUser

private MetricsUserSource getOrCreateMetricsUser(String user)