public class oadd.org.apache.drill.exec.ops.OperatorStats extends java.lang.Object
{
protected final int operatorId;
protected final java.lang.String operatorType;
private final oadd.org.apache.drill.exec.memory.BufferAllocator allocator;
private final oadd.com.carrotsearch.hppc.IntLongHashMap longMetrics;
private final oadd.com.carrotsearch.hppc.IntDoubleHashMap doubleMetrics;
public long[] recordsReceivedByInput;
public long[] batchesReceivedByInput;
private final long[] schemaCountByInput;
private boolean inProcessing;
private boolean inSetup;
private boolean inWait;
protected long processingNanos;
protected long setupNanos;
protected long waitNanos;
private long processingMark;
private long setupMark;
private long waitMark;
private final int inputCount;
static final boolean $assertionsDisabled;
public void <init>(oadd.org.apache.drill.exec.ops.OpProfileDef, oadd.org.apache.drill.exec.memory.BufferAllocator)
{
oadd.org.apache.drill.exec.ops.OpProfileDef v;
oadd.org.apache.drill.exec.ops.OperatorStats v;
int v, v;
oadd.org.apache.drill.exec.memory.BufferAllocator v;
java.lang.String v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: oadd.org.apache.drill.exec.ops.OpProfileDef;
v := @parameter: oadd.org.apache.drill.exec.memory.BufferAllocator;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ops.OpProfileDef: int getOperatorId()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.ops.OpProfileDef: java.lang.String getOperatorType()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.ops.OpProfileDef: int getIncomingCount()>();
specialinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: void <init>(int,java.lang.String,int,oadd.org.apache.drill.exec.memory.BufferAllocator)>(v, v, v, v);
return;
}
public void <init>(oadd.org.apache.drill.exec.ops.OperatorStats, boolean)
{
oadd.org.apache.drill.exec.ops.OperatorStats v, v;
long v, v, v;
int v, v;
oadd.org.apache.drill.exec.memory.BufferAllocator v;
java.lang.String v;
boolean v, v, v, v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: boolean;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: int operatorId>;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: java.lang.String operatorType>;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: int inputCount>;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
specialinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: void <init>(int,java.lang.String,int,oadd.org.apache.drill.exec.memory.BufferAllocator)>(v, v, v, v);
if v != 0 goto label;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inProcessing>;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inProcessing> = v;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inSetup>;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inSetup> = v;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inWait>;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inWait> = v;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long processingMark>;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: long processingMark> = v;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long setupMark>;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: long setupMark> = v;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long waitMark>;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: long waitMark> = v;
label:
return;
}
public void <init>(int, java.lang.String, int, oadd.org.apache.drill.exec.memory.BufferAllocator)
{
oadd.com.carrotsearch.hppc.IntDoubleHashMap v;
oadd.org.apache.drill.exec.ops.OperatorStats v;
oadd.com.carrotsearch.hppc.IntLongHashMap v;
long[] v, v, v;
int v, v;
oadd.org.apache.drill.exec.memory.BufferAllocator v;
java.lang.String v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: int;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: oadd.org.apache.drill.exec.memory.BufferAllocator;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new oadd.com.carrotsearch.hppc.IntLongHashMap;
specialinvoke v.<oadd.com.carrotsearch.hppc.IntLongHashMap: void <init>()>();
v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntLongHashMap longMetrics> = v;
v = new oadd.com.carrotsearch.hppc.IntDoubleHashMap;
specialinvoke v.<oadd.com.carrotsearch.hppc.IntDoubleHashMap: void <init>()>();
v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntDoubleHashMap doubleMetrics> = v;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.org.apache.drill.exec.memory.BufferAllocator allocator> = v;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: int operatorId> = v;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: java.lang.String operatorType> = v;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: int inputCount> = v;
v = newarray (long)[v];
v.<oadd.org.apache.drill.exec.ops.OperatorStats: long[] recordsReceivedByInput> = v;
v = newarray (long)[v];
v.<oadd.org.apache.drill.exec.ops.OperatorStats: long[] batchesReceivedByInput> = v;
v = newarray (long)[v];
v.<oadd.org.apache.drill.exec.ops.OperatorStats: long[] schemaCountByInput> = v;
return;
}
private java.lang.String assertionError(java.lang.String)
{
java.lang.Object[] v;
oadd.org.apache.drill.exec.ops.OperatorStats v;
java.lang.Integer v;
int v;
java.lang.Boolean v, v, v;
java.lang.String v, v;
boolean v, v, v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: java.lang.String;
v = newarray (java.lang.Object)[5];
v[0] = v;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: int operatorId>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inProcessing>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v[2] = v;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inSetup>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v[3] = v;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inWait>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v[4] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Failure while %s for operator id %d. Currently have states of processing:%s, setup:%s, waiting:%s.", v);
return v;
}
public oadd.org.apache.drill.exec.ops.OperatorStats mergeMetrics(oadd.org.apache.drill.exec.ops.OperatorStats)
{
oadd.com.carrotsearch.hppc.IntDoubleHashMap v, v;
long v, v;
int v, v;
boolean v, v;
double v, v;
java.util.Iterator v, v;
oadd.org.apache.drill.exec.ops.OperatorStats v, v;
oadd.com.carrotsearch.hppc.IntLongHashMap v, v;
java.lang.Object v, v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: oadd.org.apache.drill.exec.ops.OperatorStats;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntLongHashMap longMetrics>;
v = virtualinvoke v.<oadd.com.carrotsearch.hppc.IntLongHashMap: 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.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntLongHashMap longMetrics>;
v = v.<oadd.com.carrotsearch.hppc.cursors.IntLongCursor: int key>;
v = v.<oadd.com.carrotsearch.hppc.cursors.IntLongCursor: long value>;
v = v.<oadd.com.carrotsearch.hppc.cursors.IntLongCursor: long value>;
virtualinvoke v.<oadd.com.carrotsearch.hppc.IntLongHashMap: long putOrAdd(int,long,long)>(v, v, v);
goto label;
label:
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntDoubleHashMap doubleMetrics>;
v = virtualinvoke v.<oadd.com.carrotsearch.hppc.IntDoubleHashMap: 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.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntDoubleHashMap doubleMetrics>;
v = v.<oadd.com.carrotsearch.hppc.cursors.IntDoubleCursor: int key>;
v = v.<oadd.com.carrotsearch.hppc.cursors.IntDoubleCursor: double value>;
v = v.<oadd.com.carrotsearch.hppc.cursors.IntDoubleCursor: double value>;
virtualinvoke v.<oadd.com.carrotsearch.hppc.IntDoubleHashMap: double putOrAdd(int,double,double)>(v, v, v);
goto label;
label:
return v;
}
public synchronized void clear()
{
oadd.com.carrotsearch.hppc.IntLongHashMap v;
oadd.com.carrotsearch.hppc.IntDoubleHashMap v;
oadd.org.apache.drill.exec.ops.OperatorStats v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: long processingNanos> = 0L;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: long setupNanos> = 0L;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: long waitNanos> = 0L;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntLongHashMap longMetrics>;
virtualinvoke v.<oadd.com.carrotsearch.hppc.IntLongHashMap: void clear()>();
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntDoubleHashMap doubleMetrics>;
virtualinvoke v.<oadd.com.carrotsearch.hppc.IntDoubleHashMap: void clear()>();
return;
}
public synchronized void startSetup()
{
oadd.org.apache.drill.exec.ops.OperatorStats v;
long v;
java.lang.AssertionError v;
java.lang.String v;
boolean v, v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v = <oadd.org.apache.drill.exec.ops.OperatorStats: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inSetup>;
if v == 0 goto label;
v = new java.lang.AssertionError;
v = specialinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: java.lang.String assertionError(java.lang.String)>("starting setup");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
label:
virtualinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: void stopProcessing()>();
v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inSetup> = 1;
v = staticinvoke <java.lang.System: long nanoTime()>();
v.<oadd.org.apache.drill.exec.ops.OperatorStats: long setupMark> = v;
return;
}
public synchronized void stopSetup()
{
oadd.org.apache.drill.exec.ops.OperatorStats v;
long v, v, v, v, v;
java.lang.AssertionError v;
java.lang.String v;
boolean v, v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v = <oadd.org.apache.drill.exec.ops.OperatorStats: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inSetup>;
if v != 0 goto label;
v = new java.lang.AssertionError;
v = specialinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: java.lang.String assertionError(java.lang.String)>("stopping setup");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
label:
virtualinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: void startProcessing()>();
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long setupNanos>;
v = staticinvoke <java.lang.System: long nanoTime()>();
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long setupMark>;
v = v - v;
v = v + v;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: long setupNanos> = v;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inSetup> = 0;
return;
}
public synchronized void startProcessing()
{
oadd.org.apache.drill.exec.ops.OperatorStats v;
long v;
java.lang.AssertionError v;
java.lang.String v;
boolean v, v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v = <oadd.org.apache.drill.exec.ops.OperatorStats: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inProcessing>;
if v == 0 goto label;
v = new java.lang.AssertionError;
v = specialinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: java.lang.String assertionError(java.lang.String)>("starting processing");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
label:
v = staticinvoke <java.lang.System: long nanoTime()>();
v.<oadd.org.apache.drill.exec.ops.OperatorStats: long processingMark> = v;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inProcessing> = 1;
return;
}
public synchronized void stopProcessing()
{
oadd.org.apache.drill.exec.ops.OperatorStats v;
long v, v, v, v, v;
java.lang.AssertionError v;
java.lang.String v;
boolean v, v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v = <oadd.org.apache.drill.exec.ops.OperatorStats: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inProcessing>;
if v != 0 goto label;
v = new java.lang.AssertionError;
v = specialinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: java.lang.String assertionError(java.lang.String)>("stopping processing");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
label:
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long processingNanos>;
v = staticinvoke <java.lang.System: long nanoTime()>();
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long processingMark>;
v = v - v;
v = v + v;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: long processingNanos> = v;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inProcessing> = 0;
return;
}
public synchronized void startWait()
{
oadd.org.apache.drill.exec.ops.OperatorStats v;
long v;
java.lang.AssertionError v;
java.lang.String v;
boolean v, v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v = <oadd.org.apache.drill.exec.ops.OperatorStats: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inWait>;
if v == 0 goto label;
v = new java.lang.AssertionError;
v = specialinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: java.lang.String assertionError(java.lang.String)>("starting waiting");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
label:
virtualinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: void stopProcessing()>();
v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inWait> = 1;
v = staticinvoke <java.lang.System: long nanoTime()>();
v.<oadd.org.apache.drill.exec.ops.OperatorStats: long waitMark> = v;
return;
}
public synchronized void stopWait()
{
oadd.org.apache.drill.exec.ops.OperatorStats v;
long v, v, v, v, v;
java.lang.AssertionError v;
java.lang.String v;
boolean v, v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v = <oadd.org.apache.drill.exec.ops.OperatorStats: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inWait>;
if v != 0 goto label;
v = new java.lang.AssertionError;
v = specialinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: java.lang.String assertionError(java.lang.String)>("stopping waiting");
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
label:
virtualinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: void startProcessing()>();
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long waitNanos>;
v = staticinvoke <java.lang.System: long nanoTime()>();
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long waitMark>;
v = v - v;
v = v + v;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: long waitNanos> = v;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: boolean inWait> = 0;
return;
}
public synchronized void batchReceived(int, long, boolean)
{
oadd.org.apache.drill.exec.ops.OperatorStats v;
long v, v, v, v, v, v, v;
long[] v, v, v;
int v;
boolean v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: int;
v := @parameter: long;
v := @parameter: boolean;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long[] recordsReceivedByInput>;
v = v[v];
v = v + v;
v[v] = v;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long[] batchesReceivedByInput>;
v = v[v];
v = v + 1L;
v[v] = v;
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long[] schemaCountByInput>;
v = v[v];
v = v + 1L;
v[v] = v;
label:
return;
}
public java.lang.String getId()
{
oadd.org.apache.drill.exec.ops.OperatorStats v;
int v;
java.lang.String v, v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: int operatorId>;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: java.lang.String operatorType>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,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:[\u]");
return v;
}
public oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile getProfile()
{
oadd.org.apache.drill.exec.server.rest.profile.CoreOperatorType v;
long v, v, v, v;
int v, v;
java.lang.String v, v;
oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder v, v, v, v, v, v;
oadd.org.apache.drill.exec.ops.OperatorStats v;
oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile v;
oadd.org.apache.drill.exec.memory.BufferAllocator v, v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v = staticinvoke <oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile: oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder newBuilder()>();
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: java.lang.String operatorType>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder setOperatorTypeName(java.lang.String)>(v);
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: int operatorId>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder setOperatorId(int)>(v);
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long setupNanos>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder setSetupNanos(long)>(v);
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long processingNanos>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder setProcessNanos(long)>(v);
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long waitNanos>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder setWaitNanos(long)>(v);
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: java.lang.String operatorType>;
v = staticinvoke <oadd.org.apache.drill.exec.server.rest.profile.CoreOperatorType: oadd.org.apache.drill.exec.server.rest.profile.CoreOperatorType forName(java.lang.String)>(v);
if v == null goto label;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.rest.profile.CoreOperatorType: int getId()>();
virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder setOperatorType(int)>(v);
label:
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.memory.BufferAllocator: long getPeakMemoryAllocation()>();
virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder setPeakLocalMemoryAllocated(long)>(v);
label:
virtualinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: void addAllMetrics(oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile build()>();
return v;
}
public void addAllMetrics(oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder)
{
oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder v;
oadd.org.apache.drill.exec.ops.OperatorStats v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder;
virtualinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: void addStreamProfile(oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder)>(v);
virtualinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: void addLongMetrics(oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder)>(v);
virtualinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: void addDoubleMetrics(oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder)>(v);
return;
}
public void addStreamProfile(oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder)
{
oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder v;
oadd.org.apache.drill.exec.ops.OperatorStats v;
oadd.org.apache.drill.exec.proto.UserBitShared$StreamProfile$Builder v, v, v, v;
long v, v, v;
long[] v, v, v, v;
int v, v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder;
v = 0;
label:
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long[] recordsReceivedByInput>;
v = lengthof v;
if v >= v goto label;
v = staticinvoke <oadd.org.apache.drill.exec.proto.UserBitShared$StreamProfile: oadd.org.apache.drill.exec.proto.UserBitShared$StreamProfile$Builder newBuilder()>();
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long[] batchesReceivedByInput>;
v = v[v];
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$StreamProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$StreamProfile$Builder setBatches(long)>(v);
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long[] recordsReceivedByInput>;
v = v[v];
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$StreamProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$StreamProfile$Builder setRecords(long)>(v);
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long[] schemaCountByInput>;
v = v[v];
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$StreamProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$StreamProfile$Builder setSchemas(long)>(v);
virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder addInputProfile(oadd.org.apache.drill.exec.proto.UserBitShared$StreamProfile$Builder)>(v);
v = v + 1;
goto label;
label:
return;
}
public void addLongMetrics(oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder)
{
oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder v;
oadd.org.apache.drill.exec.ops.OperatorStats v;
oadd.org.apache.drill.exec.ops.OperatorStats$LongProc v;
int v;
oadd.com.carrotsearch.hppc.IntLongHashMap v, v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntLongHashMap longMetrics>;
v = virtualinvoke v.<oadd.com.carrotsearch.hppc.IntLongHashMap: int size()>();
if v <= 0 goto label;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntLongHashMap longMetrics>;
v = new oadd.org.apache.drill.exec.ops.OperatorStats$LongProc;
specialinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats$LongProc: void <init>(oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder)>(v);
virtualinvoke v.<oadd.com.carrotsearch.hppc.IntLongHashMap: oadd.com.carrotsearch.hppc.procedures.IntLongProcedure forEach(oadd.com.carrotsearch.hppc.procedures.IntLongProcedure)>(v);
label:
return;
}
public void addDoubleMetrics(oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder)
{
oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder v;
oadd.com.carrotsearch.hppc.IntDoubleHashMap v, v;
oadd.org.apache.drill.exec.ops.OperatorStats v;
int v;
oadd.org.apache.drill.exec.ops.OperatorStats$DoubleProc v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntDoubleHashMap doubleMetrics>;
v = virtualinvoke v.<oadd.com.carrotsearch.hppc.IntDoubleHashMap: int size()>();
if v <= 0 goto label;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntDoubleHashMap doubleMetrics>;
v = new oadd.org.apache.drill.exec.ops.OperatorStats$DoubleProc;
specialinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats$DoubleProc: void <init>(oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile$Builder)>(v);
virtualinvoke v.<oadd.com.carrotsearch.hppc.IntDoubleHashMap: oadd.com.carrotsearch.hppc.procedures.IntDoubleProcedure forEach(oadd.com.carrotsearch.hppc.procedures.IntDoubleProcedure)>(v);
label:
return;
}
public void addLongStat(oadd.org.apache.drill.exec.ops.MetricDef, long)
{
oadd.org.apache.drill.exec.ops.OperatorStats v;
int v;
oadd.com.carrotsearch.hppc.IntLongHashMap v;
oadd.org.apache.drill.exec.ops.MetricDef v;
long v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: oadd.org.apache.drill.exec.ops.MetricDef;
v := @parameter: long;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntLongHashMap longMetrics>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.MetricDef: int metricId()>();
virtualinvoke v.<oadd.com.carrotsearch.hppc.IntLongHashMap: long putOrAdd(int,long,long)>(v, v, v);
return;
}
public long getLongStat(oadd.org.apache.drill.exec.ops.MetricDef)
{
oadd.org.apache.drill.exec.ops.OperatorStats v;
int v;
oadd.com.carrotsearch.hppc.IntLongHashMap v;
oadd.org.apache.drill.exec.ops.MetricDef v;
long v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: oadd.org.apache.drill.exec.ops.MetricDef;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntLongHashMap longMetrics>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.MetricDef: int metricId()>();
v = virtualinvoke v.<oadd.com.carrotsearch.hppc.IntLongHashMap: long get(int)>(v);
return v;
}
public void addDoubleStat(oadd.org.apache.drill.exec.ops.MetricDef, double)
{
oadd.com.carrotsearch.hppc.IntDoubleHashMap v;
oadd.org.apache.drill.exec.ops.OperatorStats v;
int v;
oadd.org.apache.drill.exec.ops.MetricDef v;
double v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: oadd.org.apache.drill.exec.ops.MetricDef;
v := @parameter: double;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntDoubleHashMap doubleMetrics>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.MetricDef: int metricId()>();
virtualinvoke v.<oadd.com.carrotsearch.hppc.IntDoubleHashMap: double putOrAdd(int,double,double)>(v, v, v);
return;
}
public double getDoubleStat(oadd.org.apache.drill.exec.ops.MetricDef)
{
oadd.com.carrotsearch.hppc.IntDoubleHashMap v;
oadd.org.apache.drill.exec.ops.OperatorStats v;
int v;
oadd.org.apache.drill.exec.ops.MetricDef v;
double v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: oadd.org.apache.drill.exec.ops.MetricDef;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntDoubleHashMap doubleMetrics>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.MetricDef: int metricId()>();
v = virtualinvoke v.<oadd.com.carrotsearch.hppc.IntDoubleHashMap: double get(int)>(v);
return v;
}
public void setLongStat(oadd.org.apache.drill.exec.ops.MetricDef, long)
{
oadd.org.apache.drill.exec.ops.OperatorStats v;
int v;
oadd.com.carrotsearch.hppc.IntLongHashMap v;
oadd.org.apache.drill.exec.ops.MetricDef v;
long v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: oadd.org.apache.drill.exec.ops.MetricDef;
v := @parameter: long;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntLongHashMap longMetrics>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.MetricDef: int metricId()>();
virtualinvoke v.<oadd.com.carrotsearch.hppc.IntLongHashMap: long put(int,long)>(v, v);
return;
}
public void setDoubleStat(oadd.org.apache.drill.exec.ops.MetricDef, double)
{
oadd.com.carrotsearch.hppc.IntDoubleHashMap v;
oadd.org.apache.drill.exec.ops.OperatorStats v;
int v;
oadd.org.apache.drill.exec.ops.MetricDef v;
double v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: oadd.org.apache.drill.exec.ops.MetricDef;
v := @parameter: double;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.com.carrotsearch.hppc.IntDoubleHashMap doubleMetrics>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.MetricDef: int metricId()>();
virtualinvoke v.<oadd.com.carrotsearch.hppc.IntDoubleHashMap: double put(int,double)>(v, v);
return;
}
public long getWaitNanos()
{
long v;
oadd.org.apache.drill.exec.ops.OperatorStats v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long waitNanos>;
return v;
}
public void adjustWaitNanos(long)
{
oadd.org.apache.drill.exec.ops.OperatorStats v;
long v, v, v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v := @parameter: long;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long waitNanos>;
v = v + v;
v.<oadd.org.apache.drill.exec.ops.OperatorStats: long waitNanos> = v;
return;
}
public long getProcessingNanos()
{
long v;
oadd.org.apache.drill.exec.ops.OperatorStats v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorStats;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: long processingNanos>;
return v;
}
static void <clinit>()
{
java.lang.Class v;
boolean v, v;
v = class "Loadd/org/apache/drill/exec/ops/OperatorStats;";
v = virtualinvoke v.<java.lang.Class: boolean desiredAssertionStatus()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
<oadd.org.apache.drill.exec.ops.OperatorStats: boolean $assertionsDisabled> = v;
return;
}
}