public class oadd.org.apache.drill.exec.ops.FragmentStats extends java.lang.Object
{
private final java.util.Map operators;
private final long startTime;
private final oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint endpoint;
private final oadd.org.apache.drill.exec.memory.BufferAllocator allocator;
public void <init>(oadd.org.apache.drill.exec.memory.BufferAllocator, oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint)
{
java.util.LinkedHashMap v;
oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint v;
oadd.org.apache.drill.exec.memory.BufferAllocator v;
long v;
oadd.org.apache.drill.exec.ops.FragmentStats v;
v := @this: oadd.org.apache.drill.exec.ops.FragmentStats;
v := @parameter: oadd.org.apache.drill.exec.memory.BufferAllocator;
v := @parameter: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v.<oadd.org.apache.drill.exec.ops.FragmentStats: java.util.Map operators> = v;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v.<oadd.org.apache.drill.exec.ops.FragmentStats: long startTime> = v;
v.<oadd.org.apache.drill.exec.ops.FragmentStats: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint endpoint> = v;
v.<oadd.org.apache.drill.exec.ops.FragmentStats: oadd.org.apache.drill.exec.memory.BufferAllocator allocator> = v;
return;
}
public void addMetricsToStatus(oadd.org.apache.drill.exec.proto.UserBitShared$MinorFragmentProfile$Builder)
{
java.util.Iterator v;
oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile v;
java.util.Set v;
oadd.org.apache.drill.exec.proto.UserBitShared$MinorFragmentProfile$Builder v;
long v, v, v;
oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint v;
java.util.Map v;
oadd.org.apache.drill.exec.memory.BufferAllocator v;
java.lang.Object v, v;
oadd.org.apache.drill.exec.ops.FragmentStats v;
boolean v;
v := @this: oadd.org.apache.drill.exec.ops.FragmentStats;
v := @parameter: oadd.org.apache.drill.exec.proto.UserBitShared$MinorFragmentProfile$Builder;
v = v.<oadd.org.apache.drill.exec.ops.FragmentStats: long startTime>;
virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$MinorFragmentProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$MinorFragmentProfile$Builder setStartTime(long)>(v);
v = v.<oadd.org.apache.drill.exec.ops.FragmentStats: 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$MinorFragmentProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$MinorFragmentProfile$Builder setMaxMemoryUsed(long)>(v);
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$MinorFragmentProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$MinorFragmentProfile$Builder setEndTime(long)>(v);
v = v.<oadd.org.apache.drill.exec.ops.FragmentStats: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint endpoint>;
virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$MinorFragmentProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$MinorFragmentProfile$Builder setEndpoint(oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint)>(v);
v = v.<oadd.org.apache.drill.exec.ops.FragmentStats: java.util.Map operators>;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: 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 = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile getProfile()>();
virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$MinorFragmentProfile$Builder: oadd.org.apache.drill.exec.proto.UserBitShared$MinorFragmentProfile$Builder addOperatorProfile(oadd.org.apache.drill.exec.proto.UserBitShared$OperatorProfile)>(v);
goto label;
label:
return;
}
public oadd.org.apache.drill.exec.ops.OperatorStats newOperatorStats(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;
oadd.org.apache.drill.exec.memory.BufferAllocator v;
java.lang.String v;
oadd.org.apache.drill.exec.ops.FragmentStats v;
v := @this: oadd.org.apache.drill.exec.ops.FragmentStats;
v := @parameter: oadd.org.apache.drill.exec.ops.OpProfileDef;
v := @parameter: oadd.org.apache.drill.exec.memory.BufferAllocator;
v = new oadd.org.apache.drill.exec.ops.OperatorStats;
specialinvoke v.<oadd.org.apache.drill.exec.ops.OperatorStats: void <init>(oadd.org.apache.drill.exec.ops.OpProfileDef,oadd.org.apache.drill.exec.memory.BufferAllocator)>(v, v);
v = v.<oadd.org.apache.drill.exec.ops.OpProfileDef: java.lang.String operatorType>;
if v == null goto label;
virtualinvoke v.<oadd.org.apache.drill.exec.ops.FragmentStats: void addOperatorStats(oadd.org.apache.drill.exec.ops.OperatorStats)>(v);
label:
return v;
}
public void addOperatorStats(oadd.org.apache.drill.exec.ops.OperatorStats)
{
oadd.org.apache.commons.lang.tuple.ImmutablePair v;
oadd.org.apache.drill.exec.ops.OperatorStats v;
java.util.Map v;
int v;
java.lang.String v;
oadd.org.apache.drill.exec.ops.FragmentStats v;
java.lang.Integer v;
v := @this: oadd.org.apache.drill.exec.ops.FragmentStats;
v := @parameter: oadd.org.apache.drill.exec.ops.OperatorStats;
v = v.<oadd.org.apache.drill.exec.ops.FragmentStats: java.util.Map operators>;
v = new oadd.org.apache.commons.lang.tuple.ImmutablePair;
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: int operatorId>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = v.<oadd.org.apache.drill.exec.ops.OperatorStats: java.lang.String operatorType>;
specialinvoke v.<oadd.org.apache.commons.lang.tuple.ImmutablePair: void <init>(java.lang.Object,java.lang.Object)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
}