class oadd.org.apache.drill.exec.ops.OperatorContextImpl extends oadd.org.apache.drill.exec.ops.BaseOperatorContext implements java.lang.AutoCloseable
{
static final org.slf4j.Logger logger;
private boolean closed;
private final oadd.org.apache.drill.exec.ops.OperatorStats stats;
private org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListeningExecutorService delegatePool;
public void <init>(oadd.org.apache.drill.exec.physical.base.PhysicalOperator, oadd.org.apache.drill.exec.ops.FragmentContextImpl) throws oadd.org.apache.drill.exec.exception.OutOfMemoryException
{
oadd.org.apache.drill.exec.ops.FragmentContextImpl v;
oadd.org.apache.drill.exec.ops.OperatorContextImpl v;
oadd.org.apache.drill.exec.physical.base.PhysicalOperator v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorContextImpl;
v := @parameter: oadd.org.apache.drill.exec.physical.base.PhysicalOperator;
v := @parameter: oadd.org.apache.drill.exec.ops.FragmentContextImpl;
specialinvoke v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: void <init>(oadd.org.apache.drill.exec.physical.base.PhysicalOperator,oadd.org.apache.drill.exec.ops.FragmentContextImpl,oadd.org.apache.drill.exec.ops.OperatorStats)>(v, v, null);
return;
}
public void <init>(oadd.org.apache.drill.exec.physical.base.PhysicalOperator, oadd.org.apache.drill.exec.ops.FragmentContextImpl, oadd.org.apache.drill.exec.ops.OperatorStats) throws oadd.org.apache.drill.exec.exception.OutOfMemoryException
{
oadd.org.apache.drill.exec.ops.FragmentContextImpl v;
oadd.org.apache.drill.exec.ops.OpProfileDef v;
long v, v;
oadd.org.apache.drill.exec.ops.OperatorContextImpl v;
int v, v, v;
java.lang.String v, v;
oadd.org.apache.drill.exec.ops.FragmentStats v;
oadd.org.apache.drill.exec.ops.OperatorStats v, v;
oadd.org.apache.drill.exec.physical.base.PhysicalOperator v;
oadd.org.apache.drill.exec.memory.BufferAllocator v, v;
java.lang.Class v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorContextImpl;
v := @parameter: oadd.org.apache.drill.exec.physical.base.PhysicalOperator;
v := @parameter: oadd.org.apache.drill.exec.ops.FragmentContextImpl;
v := @parameter: oadd.org.apache.drill.exec.ops.OperatorStats;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = interfaceinvoke v.<oadd.org.apache.drill.exec.physical.base.PhysicalOperator: int getOperatorId()>();
v = interfaceinvoke v.<oadd.org.apache.drill.exec.physical.base.PhysicalOperator: long getInitialAllocation()>();
v = interfaceinvoke v.<oadd.org.apache.drill.exec.physical.base.PhysicalOperator: long getMaxAllocation()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.ops.FragmentContextImpl: oadd.org.apache.drill.exec.memory.BufferAllocator getNewChildAllocator(java.lang.String,int,long,long)>(v, v, v, v);
specialinvoke v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: void <init>(oadd.org.apache.drill.exec.ops.FragmentContext,oadd.org.apache.drill.exec.memory.BufferAllocator,oadd.org.apache.drill.exec.physical.base.PhysicalOperator)>(v, v, v);
v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: boolean closed> = 0;
if v == null goto label;
v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: oadd.org.apache.drill.exec.ops.OperatorStats stats> = v;
goto label;
label:
v = new oadd.org.apache.drill.exec.ops.OpProfileDef;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.physical.base.PhysicalOperator: int getOperatorId()>();
v = interfaceinvoke v.<oadd.org.apache.drill.exec.physical.base.PhysicalOperator: java.lang.String getOperatorType()>();
v = staticinvoke <oadd.org.apache.drill.exec.ops.OperatorUtilities: int getChildCount(oadd.org.apache.drill.exec.physical.base.PhysicalOperator)>(v);
specialinvoke v.<oadd.org.apache.drill.exec.ops.OpProfileDef: void <init>(int,java.lang.String,int)>(v, v, v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.ops.FragmentContextImpl: oadd.org.apache.drill.exec.ops.FragmentStats getStats()>();
v = v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ops.FragmentStats: oadd.org.apache.drill.exec.ops.OperatorStats newOperatorStats(oadd.org.apache.drill.exec.ops.OpProfileDef,oadd.org.apache.drill.exec.memory.BufferAllocator)>(v, v);
v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: oadd.org.apache.drill.exec.ops.OperatorStats stats> = v;
label:
return;
}
public boolean isClosed()
{
oadd.org.apache.drill.exec.ops.OperatorContextImpl v;
boolean v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorContextImpl;
v = v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: boolean closed>;
return v;
}
public void close()
{
org.slf4j.Logger v, v;
oadd.org.apache.drill.exec.ops.OperatorContextImpl v;
oadd.org.apache.drill.exec.physical.base.PhysicalOperator v, v;
java.lang.String v, v;
boolean v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorContextImpl;
v = v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: boolean closed>;
if v == 0 goto label;
v = <oadd.org.apache.drill.exec.ops.OperatorContextImpl: org.slf4j.Logger logger>;
v = v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: oadd.org.apache.drill.exec.physical.base.PhysicalOperator popConfig>;
if v == null goto label;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: java.lang.String getName()>();
goto label;
label:
v = null;
label:
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Attempted to close Operator context for {}, but context is already closed", v);
return;
label:
v = <oadd.org.apache.drill.exec.ops.OperatorContextImpl: org.slf4j.Logger logger>;
v = v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: oadd.org.apache.drill.exec.physical.base.PhysicalOperator popConfig>;
if v == null goto label;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: java.lang.String getName()>();
goto label;
label:
v = null;
label:
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Closing context for {}", v);
v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: boolean closed> = 1;
specialinvoke v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: void close()>();
return;
}
public oadd.org.apache.drill.exec.ops.OperatorStats getStats()
{
oadd.org.apache.drill.exec.ops.OperatorContextImpl v;
oadd.org.apache.drill.exec.ops.OperatorStats v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorContextImpl;
v = v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: oadd.org.apache.drill.exec.ops.OperatorStats stats>;
return v;
}
public org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture runCallableAs(oadd.org.apache.hadoop.security.UserGroupInformation, java.util.concurrent.Callable)
{
java.lang.Throwable v;
oadd.org.apache.hadoop.security.UserGroupInformation v;
oadd.org.apache.drill.exec.ops.OperatorContextImpl$1 v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListeningExecutorService v, v, v;
java.util.concurrent.Callable v;
oadd.org.apache.drill.exec.ops.OperatorContextImpl v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture v;
java.util.concurrent.ExecutorService v;
v := @this: oadd.org.apache.drill.exec.ops.OperatorContextImpl;
v := @parameter: oadd.org.apache.hadoop.security.UserGroupInformation;
v := @parameter: java.util.concurrent.Callable;
entermonitor v;
label:
v = v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListeningExecutorService delegatePool>;
if v != null goto label;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: java.util.concurrent.ExecutorService getExecutor()>();
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.util.concurrent.MoreExecutors: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListeningExecutorService listeningDecorator(java.util.concurrent.ExecutorService)>(v);
v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListeningExecutorService delegatePool> = v;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListeningExecutorService delegatePool>;
v = new oadd.org.apache.drill.exec.ops.OperatorContextImpl$1;
specialinvoke v.<oadd.org.apache.drill.exec.ops.OperatorContextImpl$1: void <init>(oadd.org.apache.drill.exec.ops.OperatorContextImpl,oadd.org.apache.hadoop.security.UserGroupInformation,java.util.concurrent.Callable)>(v, v, v);
v = interfaceinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListeningExecutorService: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture submit(java.util.concurrent.Callable)>(v);
return v;
catch java.lang.Throwable from label to label with label;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/drill/exec/ops/OperatorContextImpl;");
<oadd.org.apache.drill.exec.ops.OperatorContextImpl: org.slf4j.Logger logger> = v;
return;
}
}