org.apache.drill.exec.ops

Interface OperatorContext

All Known Implementing Classes:

BaseOperatorContext

public interface OperatorContext

Per-operator services available for operator implementations. The services allow access to the operator definition, to the fragment context, and to per-operator services.

Use this interface in code to allow unit tests to provide test-time implementations of this context.

Method Summary

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> T	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> void	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)

Method Detail

getOperatorDefn

<T extends PhysicalOperator> T getOperatorDefn()

Return the physical operator definition created by the planner and passed into the Drillbit executing the query.

Returns:

the physical operator definition

getAllocator

BufferAllocator getAllocator()

Return the memory allocator for this operator.

Returns:

the per-operator memory allocator

getFragmentContext

FragmentContext getFragmentContext()

replace

DrillBuf replace(DrillBuf old,
                 int newSize)

getManagedBuffer

DrillBuf getManagedBuffer()

getManagedBuffer

DrillBuf getManagedBuffer(int size)

getExecutionControls

ExecutionControls getExecutionControls()

getStats

OperatorStats getStats()

Drill statistics mechanism. Allows operators to update statistics.

Returns:

operator statistics

getExecutor

ExecutorService getExecutor()

getScanExecutor

ExecutorService getScanExecutor()

getScanDecodeExecutor

ExecutorService getScanDecodeExecutor()

newFileSystem

DrillFileSystem newFileSystem(org.apache.hadoop.conf.Configuration conf)
                       throws IOException

Throws:

IOException

newNonTrackingFileSystem

DrillFileSystem newNonTrackingFileSystem(org.apache.hadoop.conf.Configuration conf)
                                  throws IOException

Throws:

IOException

runCallableAs

<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.

Type Parameters:

RESULT - result type

Parameters:

proxyUgi - proxy user group information

callable - callable to run

Returns:

Future future with the result of calling the callable

setInjector

void setInjector(ControlsInjector injector)

getInjector

ControlsInjector getInjector()

Returns the fault injection mechanism used to introduce faults at runtime for testing.

Returns:

the fault injector

injectUnchecked

void injectUnchecked(String desc)

Insert an unchecked fault (exception). Handles the details of checking if fault injection is enabled and this particular fault is selected.

Parameters:

desc - the description of the fault used to match a fault injection parameter to determine if the fault should be injected

Throws:

RuntimeException - an unchecked exception if the fault is enabled

injectChecked

<T extends Throwable> void injectChecked(String desc,
                                         Class<T> exceptionClass)
                                  throws T extends Throwable

Insert a checked fault (exception) of the given class. Handles the details of checking if fault injection is enabled and this particular fault is selected.

Parameters:

desc - the description of the fault used to match a fault injection parameter to determine if the fault should be injected

exceptionClass - the class of exeception to be thrown

Throws:

T - if the fault is enabled

T extends Throwable

close

void close()