@InterfaceAudience.Private public class MetricsUserAggregateSourceImpl extends BaseSourceImpl implements MetricsUserAggregateSource
| Modifier and Type | Field and Description |
|---|---|
private static org.slf4j.Logger |
LOG |
private ConcurrentHashMap<String,MetricsUserSource> |
userSources |
metricsAdapter, metricsContext, metricsDescription, metricsJmxContext, metricsName, metricsRegistry, registryMETRICS_CONTEXT, METRICS_DESCRIPTION, METRICS_JMX_CONTEXT, METRICS_NAME, NUM_USERS, NUMBER_OF_USERS_DESCHBASE_METRICS_SYSTEM_NAME| Constructor and Description |
|---|
MetricsUserAggregateSourceImpl() |
MetricsUserAggregateSourceImpl(String metricsName,
String metricsDescription,
String metricsContext,
String metricsJmxContext) |
| Modifier and Type | Method and Description |
|---|---|
void |
deregister(MetricsUserSource toRemove) |
void |
getMetrics(org.apache.hadoop.metrics2.MetricsCollector collector,
boolean all) |
MetricsUserSource |
getOrCreateMetricsUser(String user)
Returns a MetricsUserSource if already exists, or creates and registers one for this user
|
Map<String,MetricsUserSource> |
getUserSources() |
void |
register(MetricsUserSource source) |
decGauge, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, getMetricsRegistry, incCounters, incGauge, init, removeMetric, setGauge, updateHistogramclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitdecGauge, getMetricRegistryInfo, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, incCounters, incGauge, init, removeMetric, setGauge, updateHistogramprivate static final org.slf4j.Logger LOG
private final ConcurrentHashMap<String,MetricsUserSource> userSources
public MetricsUserAggregateSourceImpl()
public MetricsUserAggregateSourceImpl(String metricsName, String metricsDescription, String metricsContext, String metricsJmxContext)
public MetricsUserSource getOrCreateMetricsUser(String user)
MetricsUserAggregateSourcegetOrCreateMetricsUser in interface MetricsUserAggregateSourceuser - the user namepublic void register(MetricsUserSource source)
public void deregister(MetricsUserSource toRemove)
deregister in interface MetricsUserAggregateSourcepublic Map<String,MetricsUserSource> getUserSources()
getUserSources in interface MetricsUserAggregateSourcepublic void getMetrics(org.apache.hadoop.metrics2.MetricsCollector collector, boolean all)
getMetrics in interface org.apache.hadoop.metrics2.MetricsSourcegetMetrics in class BaseSourceImplCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.