public interface OperatorContext
Use this interface in code to allow unit tests to provide test-time implementations of this context.
Modifier and Type | Method and Description |
---|---|
void |
close() |
BufferAllocator |
getAllocator()
Return the memory allocator for this operator.
|
ExecutionControls |
getExecutionControls() |
ExecutorService |
getExecutor() |
FragmentContext |
getFragmentContext() |
ControlsInjector |
getInjector()
Returns the fault injection mechanism used to introduce faults at runtime
for testing.
|
DrillBuf |
getManagedBuffer() |
DrillBuf |
getManagedBuffer(int size) |
<T extends PhysicalOperator> |
getOperatorDefn()
Return the physical operator definition created by the planner and passed
into the Drillbit executing the query.
|
ExecutorService |
getScanDecodeExecutor() |
ExecutorService |
getScanExecutor() |
OperatorStats |
getStats()
Drill statistics mechanism.
|
<T extends Throwable> |
injectChecked(String desc,
Class<T> exceptionClass)
Insert a checked fault (exception) of the given class.
|
void |
injectUnchecked(String desc)
Insert an unchecked fault (exception).
|
DrillFileSystem |
newFileSystem(org.apache.hadoop.conf.Configuration conf) |
DrillFileSystem |
newNonTrackingFileSystem(org.apache.hadoop.conf.Configuration conf) |
DrillBuf |
replace(DrillBuf old,
int newSize) |
<RESULT> org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture<RESULT> |
runCallableAs(org.apache.hadoop.security.UserGroupInformation proxyUgi,
Callable<RESULT> callable)
Run the callable as the given proxy user.
|
void |
setInjector(ControlsInjector injector) |
<T extends PhysicalOperator> T getOperatorDefn()
BufferAllocator getAllocator()
FragmentContext getFragmentContext()
DrillBuf getManagedBuffer()
DrillBuf getManagedBuffer(int size)
ExecutionControls getExecutionControls()
OperatorStats getStats()
ExecutorService getExecutor()
ExecutorService getScanExecutor()
ExecutorService getScanDecodeExecutor()
DrillFileSystem newFileSystem(org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
DrillFileSystem newNonTrackingFileSystem(org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
<RESULT> org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture<RESULT> runCallableAs(org.apache.hadoop.security.UserGroupInformation proxyUgi, Callable<RESULT> callable)
RESULT
- result typeproxyUgi
- proxy user group informationcallable
- callable to runvoid setInjector(ControlsInjector injector)
ControlsInjector getInjector()
void injectUnchecked(String desc)
desc
- the description of the fault used to match a fault
injection parameter to determine if the fault should be injectedRuntimeException
- an unchecked exception if the fault is enabled<T extends Throwable> void injectChecked(String desc, Class<T> exceptionClass) throws T extends Throwable
desc
- the description of the fault used to match a fault
injection parameter to determine if the fault should be injectedexceptionClass
- the class of exeception to be thrownT
- if the fault is enabledT extends Throwable
void close()
Copyright © 1970 The Apache Software Foundation. All rights reserved.