public class oadd.org.apache.hadoop.metrics.lib.MutableQuantiles extends oadd.org.apache.hadoop.metrics.lib.MutableMetric
{
public static final oadd.org.apache.hadoop.metrics.util.Quantile[] quantiles;
private final oadd.org.apache.hadoop.metrics.MetricsInfo numInfo;
private final oadd.org.apache.hadoop.metrics.MetricsInfo[] quantileInfos;
private final int interval;
private oadd.org.apache.hadoop.metrics.util.QuantileEstimator estimator;
private long previousCount;
private java.util.concurrent.ScheduledFuture scheduledTask;
protected java.util.Map previousSnapshot;
private static final java.util.concurrent.ScheduledExecutorService scheduler;
public void <init>(java.lang.String, java.lang.String, java.lang.String, java.lang.String, int)
{
java.util.concurrent.ScheduledFuture v;
java.lang.Integer v, v, v;
oadd.org.apache.hadoop.metrics.MetricsInfo[] v, v;
oadd.org.apache.hadoop.metrics.lib.MutableQuantiles$RolloverSample v;
oadd.org.apache.hadoop.metrics.MetricsInfo v, v;
oadd.org.apache.hadoop.metrics.util.SampleQuantiles v;
java.lang.Object[] v, v, v;
int v, v, v, v;
java.util.concurrent.ScheduledExecutorService v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
double v, v;
oadd.org.apache.hadoop.metrics.util.Quantile v;
java.util.concurrent.TimeUnit v;
oadd.org.apache.hadoop.metrics.util.Quantile[] v, v, v, v;
oadd.org.apache.hadoop.metrics.lib.MutableQuantiles v;
v := @this: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: int;
specialinvoke v.<oadd.org.apache.hadoop.metrics.lib.MutableMetric: void <init>()>();
v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: long previousCount> = 0L;
v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: java.util.concurrent.ScheduledFuture scheduledTask> = null;
v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: java.util.Map previousSnapshot> = null;
v = staticinvoke <oadd.org.apache.commons.lang.StringUtils: java.lang.String capitalize(java.lang.String)>(v);
v = staticinvoke <oadd.org.apache.commons.lang.StringUtils: java.lang.String capitalize(java.lang.String)>(v);
v = staticinvoke <oadd.org.apache.commons.lang.StringUtils: java.lang.String capitalize(java.lang.String)>(v);
v = staticinvoke <oadd.org.apache.commons.lang.StringUtils: java.lang.String uncapitalize(java.lang.String)>(v);
v = staticinvoke <oadd.org.apache.commons.lang.StringUtils: java.lang.String uncapitalize(java.lang.String)>(v);
v = staticinvoke <oadd.org.apache.commons.lang.StringUtils: java.lang.String uncapitalize(java.lang.String)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001Num\u0001");
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Number of %s for %s with %ds interval", v);
v = staticinvoke <oadd.org.apache.hadoop.metrics.lib.Interns: oadd.org.apache.hadoop.metrics.MetricsInfo info(java.lang.String,java.lang.String)>(v, v);
v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: oadd.org.apache.hadoop.metrics.MetricsInfo numInfo> = v;
v = <oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: oadd.org.apache.hadoop.metrics.util.Quantile[] quantiles>;
v = lengthof v;
v = newarray (oadd.org.apache.hadoop.metrics.MetricsInfo)[v];
v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: oadd.org.apache.hadoop.metrics.MetricsInfo[] quantileInfos> = v;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001%dthPercentile\u0001");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int,java.lang.String)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("%d percentile \u with \u second interval for \u0001");
v = 0;
label:
v = <oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: oadd.org.apache.hadoop.metrics.util.Quantile[] quantiles>;
v = lengthof v;
if v >= v goto label;
v = <oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: oadd.org.apache.hadoop.metrics.util.Quantile[] quantiles>;
v = v[v];
v = v.<oadd.org.apache.hadoop.metrics.util.Quantile: double quantile>;
v = 100.0 * v;
v = v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: oadd.org.apache.hadoop.metrics.MetricsInfo[] quantileInfos>;
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>(v, v);
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>(v, v);
v = staticinvoke <oadd.org.apache.hadoop.metrics.lib.Interns: oadd.org.apache.hadoop.metrics.MetricsInfo info(java.lang.String,java.lang.String)>(v, v);
v[v] = v;
v = v + 1;
goto label;
label:
v = new oadd.org.apache.hadoop.metrics.util.SampleQuantiles;
v = <oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: oadd.org.apache.hadoop.metrics.util.Quantile[] quantiles>;
specialinvoke v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: void <init>(oadd.org.apache.hadoop.metrics.util.Quantile[])>(v);
v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: oadd.org.apache.hadoop.metrics.util.QuantileEstimator estimator> = v;
v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: int interval> = v;
v = <oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: java.util.concurrent.ScheduledExecutorService scheduler>;
v = new oadd.org.apache.hadoop.metrics.lib.MutableQuantiles$RolloverSample;
specialinvoke v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles$RolloverSample: void <init>(oadd.org.apache.hadoop.metrics.lib.MutableQuantiles)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = interfaceinvoke v.<java.util.concurrent.ScheduledExecutorService: java.util.concurrent.ScheduledFuture scheduleWithFixedDelay(java.lang.Runnable,long,long,java.util.concurrent.TimeUnit)>(v, v, v, v);
v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: java.util.concurrent.ScheduledFuture scheduledTask> = v;
return;
}
public synchronized void snapshot(oadd.org.apache.hadoop.metrics.MetricsRecordBuilder, boolean)
{
long v, v;
java.util.Map v, v;
int v, v;
oadd.org.apache.hadoop.metrics.MetricsInfo[] v;
boolean v, v, v;
oadd.org.apache.hadoop.metrics.MetricsRecordBuilder v;
oadd.org.apache.hadoop.metrics.util.Quantile v;
oadd.org.apache.hadoop.metrics.util.Quantile[] v, v;
oadd.org.apache.hadoop.metrics.MetricsInfo v, v;
oadd.org.apache.hadoop.metrics.lib.MutableQuantiles v;
java.lang.Object v;
v := @this: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles;
v := @parameter: oadd.org.apache.hadoop.metrics.MetricsRecordBuilder;
v := @parameter: boolean;
if v != 0 goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: boolean changed()>();
if v == 0 goto label;
label:
v = v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: oadd.org.apache.hadoop.metrics.MetricsInfo numInfo>;
v = v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: long previousCount>;
virtualinvoke v.<oadd.org.apache.hadoop.metrics.MetricsRecordBuilder: oadd.org.apache.hadoop.metrics.MetricsRecordBuilder addGauge(oadd.org.apache.hadoop.metrics.MetricsInfo,long)>(v, v);
v = 0;
label:
v = <oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: oadd.org.apache.hadoop.metrics.util.Quantile[] quantiles>;
v = lengthof v;
if v >= v goto label;
v = 0L;
v = v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: java.util.Map previousSnapshot>;
if v == null goto label;
v = v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: java.util.Map previousSnapshot>;
v = <oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: oadd.org.apache.hadoop.metrics.util.Quantile[] quantiles>;
v = v[v];
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
label:
v = v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: oadd.org.apache.hadoop.metrics.MetricsInfo[] quantileInfos>;
v = v[v];
virtualinvoke v.<oadd.org.apache.hadoop.metrics.MetricsRecordBuilder: oadd.org.apache.hadoop.metrics.MetricsRecordBuilder addGauge(oadd.org.apache.hadoop.metrics.MetricsInfo,long)>(v, v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: boolean changed()>();
if v == 0 goto label;
virtualinvoke v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: void clearChanged()>();
label:
return;
}
public synchronized void add(long)
{
oadd.org.apache.hadoop.metrics.util.QuantileEstimator v;
oadd.org.apache.hadoop.metrics.lib.MutableQuantiles v;
long v;
v := @this: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles;
v := @parameter: long;
v = v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: oadd.org.apache.hadoop.metrics.util.QuantileEstimator estimator>;
interfaceinvoke v.<oadd.org.apache.hadoop.metrics.util.QuantileEstimator: void insert(long)>(v);
return;
}
public int getInterval()
{
int v;
oadd.org.apache.hadoop.metrics.lib.MutableQuantiles v;
v := @this: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles;
v = v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: int interval>;
return v;
}
public void stop()
{
oadd.org.apache.hadoop.metrics.lib.MutableQuantiles v;
java.util.concurrent.ScheduledFuture v, v;
v := @this: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles;
v = v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: java.util.concurrent.ScheduledFuture scheduledTask>;
if v == null goto label;
v = v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: java.util.concurrent.ScheduledFuture scheduledTask>;
interfaceinvoke v.<java.util.concurrent.ScheduledFuture: boolean cancel(boolean)>(0);
label:
v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: java.util.concurrent.ScheduledFuture scheduledTask> = null;
return;
}
public synchronized oadd.org.apache.hadoop.metrics.util.QuantileEstimator getEstimator()
{
oadd.org.apache.hadoop.metrics.util.QuantileEstimator v;
oadd.org.apache.hadoop.metrics.lib.MutableQuantiles v;
v := @this: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles;
v = v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: oadd.org.apache.hadoop.metrics.util.QuantileEstimator estimator>;
return v;
}
public synchronized void setEstimator(oadd.org.apache.hadoop.metrics.util.QuantileEstimator)
{
oadd.org.apache.hadoop.metrics.util.QuantileEstimator v;
oadd.org.apache.hadoop.metrics.lib.MutableQuantiles v;
v := @this: oadd.org.apache.hadoop.metrics.lib.MutableQuantiles;
v := @parameter: oadd.org.apache.hadoop.metrics.util.QuantileEstimator;
v.<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: oadd.org.apache.hadoop.metrics.util.QuantileEstimator estimator> = v;
return;
}
static void <clinit>()
{
oadd.com.google.common.util.concurrent.ThreadFactoryBuilder v, v, v;
oadd.org.apache.hadoop.metrics.util.Quantile v, v, v, v, v;
oadd.org.apache.hadoop.metrics.util.Quantile[] v;
java.util.concurrent.ScheduledExecutorService v;
java.util.concurrent.ThreadFactory v;
v = newarray (oadd.org.apache.hadoop.metrics.util.Quantile)[5];
v = new oadd.org.apache.hadoop.metrics.util.Quantile;
specialinvoke v.<oadd.org.apache.hadoop.metrics.util.Quantile: void <init>(double,double)>(0.5, 0.05);
v[0] = v;
v = new oadd.org.apache.hadoop.metrics.util.Quantile;
specialinvoke v.<oadd.org.apache.hadoop.metrics.util.Quantile: void <init>(double,double)>(0.75, 0.025);
v[1] = v;
v = new oadd.org.apache.hadoop.metrics.util.Quantile;
specialinvoke v.<oadd.org.apache.hadoop.metrics.util.Quantile: void <init>(double,double)>(0.9, 0.01);
v[2] = v;
v = new oadd.org.apache.hadoop.metrics.util.Quantile;
specialinvoke v.<oadd.org.apache.hadoop.metrics.util.Quantile: void <init>(double,double)>(0.95, 0.005);
v[3] = v;
v = new oadd.org.apache.hadoop.metrics.util.Quantile;
specialinvoke v.<oadd.org.apache.hadoop.metrics.util.Quantile: void <init>(double,double)>(0.99, 0.001);
v[4] = v;
<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: oadd.org.apache.hadoop.metrics.util.Quantile[] quantiles> = v;
v = new oadd.com.google.common.util.concurrent.ThreadFactoryBuilder;
specialinvoke v.<oadd.com.google.common.util.concurrent.ThreadFactoryBuilder: void <init>()>();
v = virtualinvoke v.<oadd.com.google.common.util.concurrent.ThreadFactoryBuilder: oadd.com.google.common.util.concurrent.ThreadFactoryBuilder setDaemon(boolean)>(1);
v = virtualinvoke v.<oadd.com.google.common.util.concurrent.ThreadFactoryBuilder: oadd.com.google.common.util.concurrent.ThreadFactoryBuilder setNameFormat(java.lang.String)>("MutableQuantiles-%d");
v = virtualinvoke v.<oadd.com.google.common.util.concurrent.ThreadFactoryBuilder: java.util.concurrent.ThreadFactory build()>();
v = staticinvoke <java.util.concurrent.Executors: java.util.concurrent.ScheduledExecutorService newScheduledThreadPool(int,java.util.concurrent.ThreadFactory)>(1, v);
<oadd.org.apache.hadoop.metrics.lib.MutableQuantiles: java.util.concurrent.ScheduledExecutorService scheduler> = v;
return;
}
}