public abstract class oadd.org.apache.drill.exec.ops.BaseOperatorContext extends java.lang.Object implements oadd.org.apache.drill.exec.ops.OperatorContext
{
static final org.slf4j.Logger logger;
protected final oadd.org.apache.drill.exec.ops.FragmentContext context;
protected final oadd.org.apache.drill.exec.memory.BufferAllocator allocator;
protected final oadd.org.apache.drill.exec.physical.base.PhysicalOperator popConfig;
protected final oadd.org.apache.drill.exec.ops.BufferManager manager;
private java.util.List fileSystems;
private oadd.org.apache.drill.exec.testing.ControlsInjector injector;
private boolean allowCreatingFileSystem;
public void <init>(oadd.org.apache.drill.exec.ops.FragmentContext, oadd.org.apache.drill.exec.memory.BufferAllocator, oadd.org.apache.drill.exec.physical.base.PhysicalOperator)
{
oadd.org.apache.drill.exec.ops.BufferManagerImpl v;
oadd.org.apache.drill.exec.ops.FragmentContext v;
oadd.org.apache.drill.exec.physical.base.PhysicalOperator v;
oadd.org.apache.drill.exec.memory.BufferAllocator v;
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
java.util.ArrayList v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v := @parameter: oadd.org.apache.drill.exec.ops.FragmentContext;
v := @parameter: oadd.org.apache.drill.exec.memory.BufferAllocator;
v := @parameter: oadd.org.apache.drill.exec.physical.base.PhysicalOperator;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: boolean allowCreatingFileSystem> = 1;
v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.ops.FragmentContext context> = v;
v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.memory.BufferAllocator allocator> = v;
v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.physical.base.PhysicalOperator popConfig> = v;
v = new oadd.org.apache.drill.exec.ops.BufferManagerImpl;
specialinvoke v.<oadd.org.apache.drill.exec.ops.BufferManagerImpl: void <init>(oadd.org.apache.drill.exec.memory.BufferAllocator)>(v);
v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.ops.BufferManager manager> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: java.util.List fileSystems> = v;
return;
}
public oadd.org.apache.drill.exec.ops.FragmentContext getFragmentContext()
{
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
oadd.org.apache.drill.exec.ops.FragmentContext v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.ops.FragmentContext context>;
return v;
}
public oadd.org.apache.drill.exec.physical.base.PhysicalOperator getOperatorDefn()
{
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
oadd.org.apache.drill.exec.physical.base.PhysicalOperator v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.physical.base.PhysicalOperator popConfig>;
return v;
}
public java.lang.String getName()
{
oadd.org.apache.drill.exec.physical.base.PhysicalOperator v;
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
java.lang.Class v;
java.lang.String v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.physical.base.PhysicalOperator popConfig>;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
return v;
}
public oadd.io.netty.buffer.DrillBuf replace(oadd.io.netty.buffer.DrillBuf, int)
{
oadd.io.netty.buffer.DrillBuf v, v;
int v;
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
oadd.org.apache.drill.exec.ops.BufferManager v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v := @parameter: oadd.io.netty.buffer.DrillBuf;
v := @parameter: int;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.ops.BufferManager manager>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.BufferManager: oadd.io.netty.buffer.DrillBuf replace(oadd.io.netty.buffer.DrillBuf,int)>(v, v);
return v;
}
public oadd.io.netty.buffer.DrillBuf getManagedBuffer()
{
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
oadd.io.netty.buffer.DrillBuf v;
oadd.org.apache.drill.exec.ops.BufferManager v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.ops.BufferManager manager>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.BufferManager: oadd.io.netty.buffer.DrillBuf getManagedBuffer()>();
return v;
}
public oadd.io.netty.buffer.DrillBuf getManagedBuffer(int)
{
oadd.io.netty.buffer.DrillBuf v;
int v;
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
oadd.org.apache.drill.exec.ops.BufferManager v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v := @parameter: int;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.ops.BufferManager manager>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.BufferManager: oadd.io.netty.buffer.DrillBuf getManagedBuffer(int)>(v);
return v;
}
public oadd.org.apache.drill.exec.testing.ExecutionControls getExecutionControls()
{
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
oadd.org.apache.drill.exec.testing.ExecutionControls v;
oadd.org.apache.drill.exec.ops.FragmentContext v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.ops.FragmentContext context>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.FragmentContext: oadd.org.apache.drill.exec.testing.ExecutionControls getExecutionControls()>();
return v;
}
public oadd.org.apache.drill.exec.memory.BufferAllocator getAllocator()
{
java.lang.UnsupportedOperationException v;
oadd.org.apache.drill.exec.memory.BufferAllocator v, v;
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
if v != null goto label;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("Operator context does not have an allocator");
throw v;
label:
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
return v;
}
public java.util.concurrent.ExecutorService getExecutor()
{
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
oadd.org.apache.drill.exec.ops.FragmentContext v;
java.util.concurrent.ExecutorService v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.ops.FragmentContext context>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.FragmentContext: java.util.concurrent.ExecutorService getExecutor()>();
return v;
}
public java.util.concurrent.ExecutorService getScanExecutor()
{
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
oadd.org.apache.drill.exec.ops.FragmentContext v;
java.util.concurrent.ExecutorService v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.ops.FragmentContext context>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.FragmentContext: java.util.concurrent.ExecutorService getScanExecutor()>();
return v;
}
public java.util.concurrent.ExecutorService getScanDecodeExecutor()
{
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
oadd.org.apache.drill.exec.ops.FragmentContext v;
java.util.concurrent.ExecutorService v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.ops.FragmentContext context>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.FragmentContext: java.util.concurrent.ExecutorService getScanDecodeExecutor()>();
return v;
}
public void setInjector(oadd.org.apache.drill.exec.testing.ControlsInjector)
{
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
oadd.org.apache.drill.exec.testing.ControlsInjector v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v := @parameter: oadd.org.apache.drill.exec.testing.ControlsInjector;
v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.testing.ControlsInjector injector> = v;
return;
}
public oadd.org.apache.drill.exec.testing.ControlsInjector getInjector()
{
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
oadd.org.apache.drill.exec.testing.ControlsInjector v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.testing.ControlsInjector injector>;
return v;
}
public void injectUnchecked(java.lang.String)
{
oadd.org.apache.drill.exec.testing.ExecutionControls v;
oadd.org.apache.drill.exec.ops.FragmentContext v;
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
java.lang.String v;
oadd.org.apache.drill.exec.testing.ControlsInjector v, v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.ops.FragmentContext context>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.FragmentContext: oadd.org.apache.drill.exec.testing.ExecutionControls getExecutionControls()>();
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.testing.ControlsInjector injector>;
if v == null goto label;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.testing.ControlsInjector injector>;
interfaceinvoke v.<oadd.org.apache.drill.exec.testing.ControlsInjector: void injectUnchecked(oadd.org.apache.drill.exec.testing.ExecutionControls,java.lang.String)>(v, v);
label:
return;
}
public void injectChecked(java.lang.String, java.lang.Class) throws java.lang.Throwable
{
oadd.org.apache.drill.exec.testing.ExecutionControls v;
oadd.org.apache.drill.exec.ops.FragmentContext v;
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
java.lang.Class v;
java.lang.String v;
oadd.org.apache.drill.exec.testing.ControlsInjector v, v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Class;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.ops.FragmentContext context>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.ops.FragmentContext: oadd.org.apache.drill.exec.testing.ExecutionControls getExecutionControls()>();
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.testing.ControlsInjector injector>;
if v == null goto label;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.testing.ControlsInjector injector>;
interfaceinvoke v.<oadd.org.apache.drill.exec.testing.ControlsInjector: void injectChecked(oadd.org.apache.drill.exec.testing.ExecutionControls,java.lang.String,java.lang.Class)>(v, v, v);
label:
return;
}
public void close()
{
java.util.Iterator v;
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
java.lang.RuntimeException v, v, v, v;
java.util.List v;
oadd.org.apache.drill.exec.memory.BufferAllocator v, v;
oadd.org.apache.drill.exec.ops.BufferManager v;
boolean v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v = null;
label:
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.ops.BufferManager manager>;
interfaceinvoke v.<oadd.org.apache.drill.exec.ops.BufferManager: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = v;
label:
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
interfaceinvoke v.<oadd.org.apache.drill.exec.memory.BufferAllocator: void close()>();
label:
goto label;
label:
v := @caughtexception;
if v != null goto label;
v = v;
goto label;
label:
v = v;
label:
v = v;
label:
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: java.util.List fileSystems>;
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()>();
goto label;
label:
if v == null goto label;
throw v;
label:
return;
catch java.lang.RuntimeException from label to label with label;
catch java.lang.RuntimeException from label to label with label;
}
public oadd.org.apache.drill.exec.store.dfs.DrillFileSystem newFileSystem(oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
oadd.org.apache.drill.exec.ops.OperatorStats v;
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
java.util.List v, v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.drill.exec.store.dfs.DrillFileSystem v;
boolean v, v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: boolean allowCreatingFileSystem>;
staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: void checkState(boolean,java.lang.Object)>(v, "Only one tracking file system is allowed per Operator Context and it is already created.");
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: java.util.List fileSystems>;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: void checkState(boolean,java.lang.Object)>(v, "Non-tracking file system(-s) is(are) already created.");
v = new oadd.org.apache.drill.exec.store.dfs.DrillFileSystem;
v = virtualinvoke v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: oadd.org.apache.drill.exec.ops.OperatorStats getStats()>();
specialinvoke v.<oadd.org.apache.drill.exec.store.dfs.DrillFileSystem: void <init>(oadd.org.apache.hadoop.conf.Configuration,oadd.org.apache.drill.exec.ops.OperatorStats)>(v, v);
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: java.util.List fileSystems>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: boolean allowCreatingFileSystem> = 0;
return v;
}
public oadd.org.apache.drill.exec.store.dfs.DrillFileSystem newNonTrackingFileSystem(oadd.org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
java.util.List v;
oadd.org.apache.drill.exec.ops.BaseOperatorContext v;
oadd.org.apache.hadoop.conf.Configuration v;
oadd.org.apache.drill.exec.store.dfs.DrillFileSystem v;
boolean v;
v := @this: oadd.org.apache.drill.exec.ops.BaseOperatorContext;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: boolean allowCreatingFileSystem>;
staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: void checkState(boolean,java.lang.Object)>(v, "Only one tracking file system is allowed per Operator Context and it is already created.");
v = new oadd.org.apache.drill.exec.store.dfs.DrillFileSystem;
specialinvoke v.<oadd.org.apache.drill.exec.store.dfs.DrillFileSystem: void <init>(oadd.org.apache.hadoop.conf.Configuration,oadd.org.apache.drill.exec.ops.OperatorStats)>(v, null);
v = v.<oadd.org.apache.drill.exec.ops.BaseOperatorContext: java.util.List fileSystems>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return v;
}
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/BaseOperatorContext;");
<oadd.org.apache.drill.exec.ops.BaseOperatorContext: org.slf4j.Logger logger> = v;
return;
}
}