@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 t) |
void |
updateDelete(long t) |
void |
updateFilteredReadRequests() |
void |
updateGet(long t) |
void |
updateIncrement(long t) |
void |
updatePut(long t) |
void |
updateReadRequestCount() |
void |
updateReplay(long t) |
void |
updateScanTime(long t) |
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 t)
updateGet
in interface MetricsUserAggregate
public void updateIncrement(long t)
updateIncrement
in interface MetricsUserAggregate
public void updateAppend(long t)
updateAppend
in interface MetricsUserAggregate
public void updateReplay(long t)
updateReplay
in interface MetricsUserAggregate
public void updateScanTime(long t)
updateScanTime
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.