public class oadd.org.apache.hadoop.metrics.util.SampleQuantiles extends java.lang.Object implements oadd.org.apache.hadoop.metrics.util.QuantileEstimator
{
private long count;
private java.util.LinkedList samples;
private long[] buffer;
private int bufferCount;
private final oadd.org.apache.hadoop.metrics.util.Quantile[] quantiles;
public void <init>(oadd.org.apache.hadoop.metrics.util.Quantile[])
{
oadd.org.apache.hadoop.metrics.util.Quantile[] v;
long[] v;
oadd.org.apache.hadoop.metrics.util.SampleQuantiles v;
java.util.LinkedList v;
v := @this: oadd.org.apache.hadoop.metrics.util.SampleQuantiles;
v := @parameter: oadd.org.apache.hadoop.metrics.util.Quantile[];
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: long count> = 0L;
v = newarray (long)[500];
v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: long[] buffer> = v;
v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: int bufferCount> = 0;
v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: oadd.org.apache.hadoop.metrics.util.Quantile[] quantiles> = v;
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples> = v;
return;
}
private double allowableError(int)
{
byte v, v;
int v, v, v, v, v, v;
java.util.LinkedList v;
double v, v, v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.hadoop.metrics.util.Quantile v;
oadd.org.apache.hadoop.metrics.util.Quantile[] v;
oadd.org.apache.hadoop.metrics.util.SampleQuantiles v;
v := @this: oadd.org.apache.hadoop.metrics.util.SampleQuantiles;
v := @parameter: int;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples>;
v = virtualinvoke v.<java.util.LinkedList: int size()>();
v = v + 1;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: oadd.org.apache.hadoop.metrics.util.Quantile[] quantiles>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<oadd.org.apache.hadoop.metrics.util.Quantile: double quantile>;
v = v * v;
v = v cmpg v;
if v > 0 goto label;
v = v.<oadd.org.apache.hadoop.metrics.util.Quantile: double error>;
v = 2.0 * v;
v = v - v;
v = v * v;
v = v.<oadd.org.apache.hadoop.metrics.util.Quantile: double quantile>;
v = 1.0 - v;
v = v / v;
goto label;
label:
v = v.<oadd.org.apache.hadoop.metrics.util.Quantile: double error>;
v = 2.0 * v;
v = v * v;
v = v.<oadd.org.apache.hadoop.metrics.util.Quantile: double quantile>;
v = v / v;
label:
v = v cmpg v;
if v >= 0 goto label;
v = v;
label:
v = v + 1;
goto label;
label:
return v;
}
public synchronized void insert(long)
{
long v, v, v;
long[] v, v;
oadd.org.apache.hadoop.metrics.util.SampleQuantiles v;
int v, v, v, v, v;
v := @this: oadd.org.apache.hadoop.metrics.util.SampleQuantiles;
v := @parameter: long;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: long[] buffer>;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: int bufferCount>;
v[v] = v;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: int bufferCount>;
v = v + 1;
v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: int bufferCount> = v;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: long count>;
v = v + 1L;
v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: long count> = v;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: int bufferCount>;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: long[] buffer>;
v = lengthof v;
if v != v goto label;
specialinvoke v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: void insertBatch()>();
specialinvoke v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: void compress()>();
label:
return;
}
private void insertBatch()
{
java.util.ListIterator v;
byte v, v;
oadd.org.apache.hadoop.metrics.util.SampleQuantiles v;
long v, v, v, v;
long[] v, v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.LinkedList v, v, v, v, v;
double v, v;
oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem v, v;
java.lang.Object v;
v := @this: oadd.org.apache.hadoop.metrics.util.SampleQuantiles;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: int bufferCount>;
if v != 0 goto label;
return;
label:
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: long[] buffer>;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: int bufferCount>;
staticinvoke <java.util.Arrays: void sort(long[],int,int)>(v, 0, v);
v = 0;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples>;
v = virtualinvoke v.<java.util.LinkedList: int size()>();
if v != 0 goto label;
v = new oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: long[] buffer>;
v = v[0];
specialinvoke v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem: void <init>(long,int,int)>(v, 1, 0);
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples>;
virtualinvoke v.<java.util.LinkedList: boolean add(java.lang.Object)>(v);
v = 1;
label:
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples>;
v = virtualinvoke v.<java.util.LinkedList: java.util.ListIterator listIterator()>();
v = interfaceinvoke v.<java.util.ListIterator: java.lang.Object next()>();
v = v;
label:
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: int bufferCount>;
if v >= v goto label;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: long[] buffer>;
v = v[v];
label:
v = interfaceinvoke v.<java.util.ListIterator: int nextIndex()>();
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples>;
v = virtualinvoke v.<java.util.LinkedList: int size()>();
if v >= v goto label;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem: long value>;
v = v cmp v;
if v >= 0 goto label;
interfaceinvoke v.<java.util.ListIterator: java.lang.Object next()>();
goto label;
label:
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem: long value>;
v = v cmp v;
if v <= 0 goto label;
interfaceinvoke v.<java.util.ListIterator: java.lang.Object previous()>();
label:
v = interfaceinvoke v.<java.util.ListIterator: int previousIndex()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.ListIterator: int nextIndex()>();
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples>;
v = virtualinvoke v.<java.util.LinkedList: int size()>();
if v != v goto label;
label:
v = 0;
goto label;
label:
v = interfaceinvoke v.<java.util.ListIterator: int nextIndex()>();
v = specialinvoke v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: double allowableError(int)>(v);
v = staticinvoke <java.lang.Math: double floor(double)>(v);
v = v - 1;
label:
v = new oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem;
specialinvoke v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem: void <init>(long,int,int)>(v, 1, v);
interfaceinvoke v.<java.util.ListIterator: void add(java.lang.Object)>(v);
v = v;
v = v + 1;
goto label;
label:
v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: int bufferCount> = 0;
return;
}
private void compress()
{
java.util.ListIterator v;
byte v;
int v, v, v, v, v, v, v, v, v, v;
java.util.LinkedList v, v;
boolean v;
double v;
oadd.org.apache.hadoop.metrics.util.SampleQuantiles v;
java.lang.Object v;
v := @this: oadd.org.apache.hadoop.metrics.util.SampleQuantiles;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples>;
v = virtualinvoke v.<java.util.LinkedList: int size()>();
if v >= 2 goto label;
return;
label:
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples>;
v = virtualinvoke v.<java.util.LinkedList: java.util.ListIterator listIterator()>();
v = interfaceinvoke v.<java.util.ListIterator: java.lang.Object next()>();
label:
v = interfaceinvoke v.<java.util.ListIterator: boolean hasNext()>();
if v == 0 goto label;
interfaceinvoke v.<java.util.ListIterator: java.lang.Object next()>();
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem: int g>;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem: int g>;
v = v + v;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem: int delta>;
v = v + v;
v = interfaceinvoke v.<java.util.ListIterator: int previousIndex()>();
v = specialinvoke v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: double allowableError(int)>(v);
v = v cmpg v;
if v > 0 goto label;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem: int g>;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem: int g>;
v = v + v;
v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem: int g> = v;
interfaceinvoke v.<java.util.ListIterator: java.lang.Object previous()>();
interfaceinvoke v.<java.util.ListIterator: java.lang.Object previous()>();
interfaceinvoke v.<java.util.ListIterator: void remove()>();
interfaceinvoke v.<java.util.ListIterator: java.lang.Object next()>();
goto label;
label:
return;
}
private long query(double)
{
java.util.ListIterator v;
long v, v;
byte v;
int v, v, v, v, v, v, v, v, v, v, v;
java.util.LinkedList v, v, v, v, v;
boolean v, v;
double v, v, v, v;
oadd.org.apache.hadoop.metrics.util.SampleQuantiles v;
java.lang.Object v, v;
v := @this: oadd.org.apache.hadoop.metrics.util.SampleQuantiles;
v := @parameter: double;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples>;
v = virtualinvoke v.<java.util.LinkedList: boolean isEmpty()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <oadd.com.google.common.base.Preconditions: void checkState(boolean,java.lang.Object)>(v, "no data in estimator");
v = 0;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples>;
v = virtualinvoke v.<java.util.LinkedList: java.util.ListIterator listIterator()>();
v = interfaceinvoke v.<java.util.ListIterator: java.lang.Object next()>();
v = 1;
label:
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples>;
v = virtualinvoke v.<java.util.LinkedList: int size()>();
if v >= v goto label;
interfaceinvoke v.<java.util.ListIterator: java.lang.Object next()>();
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem: int g>;
v = v + v;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem: int g>;
v = v + v;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem: int delta>;
v = v + v;
v = specialinvoke v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: double allowableError(int)>(v);
v = v / 2.0;
v = v + v;
v = v cmpl v;
if v <= 0 goto label;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem: long value>;
return v;
label:
v = v + 1;
goto label;
label:
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples>;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples>;
v = virtualinvoke v.<java.util.LinkedList: int size()>();
v = v - 1;
v = virtualinvoke v.<java.util.LinkedList: java.lang.Object get(int)>(v);
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles$SampleItem: long value>;
return v;
}
public synchronized java.util.Map snapshot()
{
oadd.org.apache.hadoop.metrics.util.Quantile v, v;
long v;
oadd.org.apache.hadoop.metrics.util.Quantile[] v, v, v;
java.util.TreeMap v;
java.lang.Long v;
oadd.org.apache.hadoop.metrics.util.SampleQuantiles v;
int v, v;
java.util.LinkedList v;
boolean v;
double v;
v := @this: oadd.org.apache.hadoop.metrics.util.SampleQuantiles;
specialinvoke v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: void insertBatch()>();
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples>;
v = virtualinvoke v.<java.util.LinkedList: boolean isEmpty()>();
if v == 0 goto label;
return null;
label:
v = new java.util.TreeMap;
specialinvoke v.<java.util.TreeMap: void <init>()>();
v = 0;
label:
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: oadd.org.apache.hadoop.metrics.util.Quantile[] quantiles>;
v = lengthof v;
if v >= v goto label;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: oadd.org.apache.hadoop.metrics.util.Quantile[] quantiles>;
v = v[v];
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: oadd.org.apache.hadoop.metrics.util.Quantile[] quantiles>;
v = v[v];
v = v.<oadd.org.apache.hadoop.metrics.util.Quantile: double quantile>;
v = specialinvoke v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: long query(double)>(v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v + 1;
goto label;
label:
return v;
}
public synchronized long getCount()
{
long v;
oadd.org.apache.hadoop.metrics.util.SampleQuantiles v;
v := @this: oadd.org.apache.hadoop.metrics.util.SampleQuantiles;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: long count>;
return v;
}
public synchronized int getSampleCount()
{
int v;
java.util.LinkedList v;
oadd.org.apache.hadoop.metrics.util.SampleQuantiles v;
v := @this: oadd.org.apache.hadoop.metrics.util.SampleQuantiles;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples>;
v = virtualinvoke v.<java.util.LinkedList: int size()>();
return v;
}
public synchronized void clear()
{
java.util.LinkedList v;
oadd.org.apache.hadoop.metrics.util.SampleQuantiles v;
v := @this: oadd.org.apache.hadoop.metrics.util.SampleQuantiles;
v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: long count> = 0L;
v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: int bufferCount> = 0;
v = v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.LinkedList samples>;
virtualinvoke v.<java.util.LinkedList: void clear()>();
return;
}
public synchronized java.lang.String toString()
{
oadd.com.google.common.base.Joiner v;
oadd.com.google.common.base.Joiner$MapJoiner v;
java.util.Map v;
oadd.org.apache.hadoop.metrics.util.SampleQuantiles v;
java.lang.String v;
v := @this: oadd.org.apache.hadoop.metrics.util.SampleQuantiles;
v = virtualinvoke v.<oadd.org.apache.hadoop.metrics.util.SampleQuantiles: java.util.Map snapshot()>();
if v != null goto label;
return "[no samples]";
label:
v = staticinvoke <oadd.com.google.common.base.Joiner: oadd.com.google.common.base.Joiner on(java.lang.String)>("\n");
v = virtualinvoke v.<oadd.com.google.common.base.Joiner: oadd.com.google.common.base.Joiner$MapJoiner withKeyValueSeparator(java.lang.String)>(": ");
v = virtualinvoke v.<oadd.com.google.common.base.Joiner$MapJoiner: java.lang.String join(java.util.Map)>(v);
return v;
}
}