public class org.apache.kafkaesque.common.metrics.stats.Frequencies extends org.apache.kafkaesque.common.metrics.stats.SampledStat implements org.apache.kafkaesque.common.metrics.CompoundStat
{
private final org.apache.kafkaesque.common.metrics.stats.Frequency[] frequencies;
private final org.apache.kafkaesque.common.metrics.stats.Histogram$BinScheme binScheme;
public static org.apache.kafkaesque.common.metrics.stats.Frequencies forBooleanValues(org.apache.kafkaesque.common.MetricName, org.apache.kafkaesque.common.MetricName)
{
java.lang.Object[] v;
org.apache.kafkaesque.common.metrics.stats.Frequencies v;
java.lang.IllegalArgumentException v;
org.apache.kafkaesque.common.metrics.stats.Frequency[] v;
java.util.ArrayList v;
org.apache.kafkaesque.common.metrics.stats.Frequency v, v;
org.apache.kafkaesque.common.MetricName v, v;
int v;
boolean v;
v := @parameter: org.apache.kafkaesque.common.MetricName;
v := @parameter: org.apache.kafkaesque.common.MetricName;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
if v == null goto label;
v = new org.apache.kafkaesque.common.metrics.stats.Frequency;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Frequency: void <init>(org.apache.kafkaesque.common.MetricName,double)>(v, 0.0);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
if v == null goto label;
v = new org.apache.kafkaesque.common.metrics.stats.Frequency;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Frequency: void <init>(org.apache.kafkaesque.common.MetricName,double)>(v, 1.0);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Must specify at least one metric name");
throw v;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (org.apache.kafkaesque.common.metrics.stats.Frequency)[v];
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray(java.lang.Object[])>(v);
v = new org.apache.kafkaesque.common.metrics.stats.Frequencies;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Frequencies: void <init>(int,double,double,org.apache.kafkaesque.common.metrics.stats.Frequency[])>(2, 0.0, 1.0, v);
return v;
}
public transient void <init>(int, double, double, org.apache.kafkaesque.common.metrics.stats.Frequency[])
{
org.apache.kafkaesque.common.metrics.stats.Histogram$ConstantBinScheme v;
org.apache.kafkaesque.common.metrics.stats.Frequency[] v;
org.apache.kafkaesque.common.metrics.stats.Frequency v;
byte v, v, v;
int v, v, v, v, v;
java.lang.String v, v;
double v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.metrics.stats.Frequencies v;
java.lang.IllegalArgumentException v, v, v, v;
v := @this: org.apache.kafkaesque.common.metrics.stats.Frequencies;
v := @parameter: int;
v := @parameter: double;
v := @parameter: double;
v := @parameter: org.apache.kafkaesque.common.metrics.stats.Frequency[];
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.SampledStat: void <init>(double)>(0.0);
v = v cmpg v;
if v >= 0 goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (double,double)>(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[])>("The maximum value \u must be greater than the minimum value \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
if v >= 1 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Must be at least 1 bucket");
throw v;
label:
v = lengthof v;
if v >= v goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("More frequencies than buckets");
throw v;
label:
v.<org.apache.kafkaesque.common.metrics.stats.Frequencies: org.apache.kafkaesque.common.metrics.stats.Frequency[] frequencies> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.stats.Frequency: double centerValue()>();
v = v cmpl v;
if v > 0 goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.stats.Frequency: double centerValue()>();
v = v cmpg v;
if v >= 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.stats.Frequency: double centerValue()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (double,double,double)>(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[])>("The frequency centered at \'\u0001\' is not within the range [\u,\u]");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v + 1;
goto label;
label:
v = v - v;
v = v - 1;
v = v / v;
v = v / 2.0;
v = new org.apache.kafkaesque.common.metrics.stats.Histogram$ConstantBinScheme;
v = v - v;
v = v + v;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Histogram$ConstantBinScheme: void <init>(int,double,double)>(v, v, v);
v.<org.apache.kafkaesque.common.metrics.stats.Frequencies: org.apache.kafkaesque.common.metrics.stats.Histogram$BinScheme binScheme> = v;
return;
}
public java.util.List stats()
{
org.apache.kafkaesque.common.metrics.stats.Frequencies v;
org.apache.kafkaesque.common.metrics.CompoundStat$NamedMeasurable v;
org.apache.kafkaesque.common.metrics.stats.Frequency[] v, v;
java.util.ArrayList v;
org.apache.kafkaesque.common.metrics.stats.Frequency v;
org.apache.kafkaesque.common.metrics.stats.Frequencies$1 v;
org.apache.kafkaesque.common.MetricName v;
int v, v, v;
double v;
v := @this: org.apache.kafkaesque.common.metrics.stats.Frequencies;
v = new java.util.ArrayList;
v = v.<org.apache.kafkaesque.common.metrics.stats.Frequencies: org.apache.kafkaesque.common.metrics.stats.Frequency[] frequencies>;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = v.<org.apache.kafkaesque.common.metrics.stats.Frequencies: org.apache.kafkaesque.common.metrics.stats.Frequency[] frequencies>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.stats.Frequency: double centerValue()>();
v = new org.apache.kafkaesque.common.metrics.CompoundStat$NamedMeasurable;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.stats.Frequency: org.apache.kafkaesque.common.MetricName name()>();
v = new org.apache.kafkaesque.common.metrics.stats.Frequencies$1;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Frequencies$1: void <init>(org.apache.kafkaesque.common.metrics.stats.Frequencies,double)>(v, v);
specialinvoke v.<org.apache.kafkaesque.common.metrics.CompoundStat$NamedMeasurable: void <init>(org.apache.kafkaesque.common.MetricName,org.apache.kafkaesque.common.metrics.Measurable)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
return v;
}
public double frequency(org.apache.kafkaesque.common.metrics.MetricConfig, long, double)
{
float[] v;
long v, v, v;
org.apache.kafkaesque.common.metrics.stats.Histogram v;
byte v;
int v;
org.apache.kafkaesque.common.metrics.stats.SampledStat$Sample v;
boolean v, v;
double v, v;
java.util.Iterator v, v;
org.apache.kafkaesque.common.metrics.stats.Frequencies v;
org.apache.kafkaesque.common.metrics.MetricConfig v;
org.apache.kafkaesque.common.metrics.stats.Histogram$BinScheme v;
java.util.List v, v;
float v, v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.common.metrics.stats.Frequencies;
v := @parameter: org.apache.kafkaesque.common.metrics.MetricConfig;
v := @parameter: long;
v := @parameter: double;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.stats.Frequencies: void purgeObsoleteSamples(org.apache.kafkaesque.common.metrics.MetricConfig,long)>(v, v);
v = 0L;
v = v.<org.apache.kafkaesque.common.metrics.stats.Frequencies: java.util.List samples>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesque.common.metrics.stats.SampledStat$Sample: long eventCount>;
v = v + v;
goto label;
label:
v = v cmp 0L;
if v != 0 goto label;
return 0.0;
label:
v = 0.0F;
v = v.<org.apache.kafkaesque.common.metrics.stats.Frequencies: org.apache.kafkaesque.common.metrics.stats.Histogram$BinScheme binScheme>;
v = interfaceinvoke v.<org.apache.kafkaesque.common.metrics.stats.Histogram$BinScheme: int toBin(double)>(v);
v = v.<org.apache.kafkaesque.common.metrics.stats.Frequencies: java.util.List samples>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesque.common.metrics.stats.Frequencies$HistogramSample: org.apache.kafkaesque.common.metrics.stats.Histogram histogram>;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.stats.Histogram: float[] counts()>();
v = v[v];
v = v + v;
goto label;
label:
v = v / v;
return v;
}
double totalCount()
{
java.util.List v;
java.util.Iterator v;
org.apache.kafkaesque.common.metrics.stats.Frequencies v;
java.lang.Object v;
long v, v;
boolean v;
v := @this: org.apache.kafkaesque.common.metrics.stats.Frequencies;
v = 0L;
v = v.<org.apache.kafkaesque.common.metrics.stats.Frequencies: java.util.List samples>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.kafkaesque.common.metrics.stats.SampledStat$Sample: long eventCount>;
v = v + v;
goto label;
label:
return v;
}
public double combine(java.util.List, org.apache.kafkaesque.common.metrics.MetricConfig, long)
{
org.apache.kafkaesque.common.metrics.MetricConfig v;
java.util.List v;
org.apache.kafkaesque.common.metrics.stats.Frequencies v;
long v;
double v;
v := @this: org.apache.kafkaesque.common.metrics.stats.Frequencies;
v := @parameter: java.util.List;
v := @parameter: org.apache.kafkaesque.common.metrics.MetricConfig;
v := @parameter: long;
v = virtualinvoke v.<org.apache.kafkaesque.common.metrics.stats.Frequencies: double totalCount()>();
return v;
}
protected org.apache.kafkaesque.common.metrics.stats.Frequencies$HistogramSample newSample(long)
{
org.apache.kafkaesque.common.metrics.stats.Histogram$BinScheme v;
org.apache.kafkaesque.common.metrics.stats.Frequencies$HistogramSample v;
org.apache.kafkaesque.common.metrics.stats.Frequencies v;
long v;
v := @this: org.apache.kafkaesque.common.metrics.stats.Frequencies;
v := @parameter: long;
v = new org.apache.kafkaesque.common.metrics.stats.Frequencies$HistogramSample;
v = v.<org.apache.kafkaesque.common.metrics.stats.Frequencies: org.apache.kafkaesque.common.metrics.stats.Histogram$BinScheme binScheme>;
specialinvoke v.<org.apache.kafkaesque.common.metrics.stats.Frequencies$HistogramSample: void <init>(org.apache.kafkaesque.common.metrics.stats.Histogram$BinScheme,long)>(v, v);
return v;
}
protected void update(org.apache.kafkaesque.common.metrics.stats.SampledStat$Sample, org.apache.kafkaesque.common.metrics.MetricConfig, double, long)
{
org.apache.kafkaesque.common.metrics.MetricConfig v;
org.apache.kafkaesque.common.metrics.stats.Frequencies v;
long v;
org.apache.kafkaesque.common.metrics.stats.SampledStat$Sample v;
org.apache.kafkaesque.common.metrics.stats.Histogram v;
double v;
v := @this: org.apache.kafkaesque.common.metrics.stats.Frequencies;
v := @parameter: org.apache.kafkaesque.common.metrics.stats.SampledStat$Sample;
v := @parameter: org.apache.kafkaesque.common.metrics.MetricConfig;
v := @parameter: double;
v := @parameter: long;
v = v.<org.apache.kafkaesque.common.metrics.stats.Frequencies$HistogramSample: org.apache.kafkaesque.common.metrics.stats.Histogram histogram>;
virtualinvoke v.<org.apache.kafkaesque.common.metrics.stats.Histogram: void record(double)>(v);
return;
}
}