@InterfaceAudience.Private public class MetricsUserAggregateImpl extends Object implements MetricsUserAggregate
Modifier and Type | Field and Description |
---|---|
private MetricsUserAggregateSource |
source |
private LossyCounting<MetricsUserSource> |
userMetricLossyCounting |
private UserProvider |
userProvider
Provider for mapping principal names to Users
|
Constructor and Description |
---|
MetricsUserAggregateImpl(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and 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) |
private final UserProvider userProvider
private final MetricsUserAggregateSource source
private final LossyCounting<MetricsUserSource> userMetricLossyCounting
public MetricsUserAggregateImpl(org.apache.hadoop.conf.Configuration conf)
private String getActiveUser()
public MetricsUserAggregateSource getSource()
MetricsUserAggregate
getSource
in interface MetricsUserAggregate
public void updatePut(long t)
updatePut
in interface MetricsUserAggregate
private void incrementClientReadMetrics(MetricsUserSource userSource)
private void incrementFilteredReadRequests(MetricsUserSource userSource)
private void incrementClientWriteMetrics(MetricsUserSource userSource)
public void updateDelete(long t)
updateDelete
in interface MetricsUserAggregate
public void updateGet(long time, long blockBytesScanned)
updateGet
in interface MetricsUserAggregate
public void updateIncrement(long time, long blockBytesScanned)
updateIncrement
in interface MetricsUserAggregate
public void updateAppend(long time, long blockBytesScanned)
updateAppend
in interface MetricsUserAggregate
public void updateReplay(long t)
updateReplay
in interface MetricsUserAggregate
public void updateScan(long time, long blockBytesScanned)
updateScan
in interface MetricsUserAggregate
public void updateCheckAndMutate(long blockBytesScanned)
updateCheckAndMutate
in interface MetricsUserAggregate
public void updateFilteredReadRequests()
updateFilteredReadRequests
in interface MetricsUserAggregate
public void updateReadRequestCount()
updateReadRequestCount
in interface MetricsUserAggregate
private MetricsUserSource getOrCreateMetricsUser(String user)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.