Uses of Class
org.apache.drill.exec.testing.ExecutionControls
Packages that use ExecutionControls
Package
Description
-
Uses of ExecutionControls in org.apache.drill.exec.ops
Methods in org.apache.drill.exec.ops that return ExecutionControlsModifier and TypeMethodDescriptionBaseOperatorContext.getExecutionControls()
FragmentContext.getExecutionControls()
Return the set of execution controls used to inject faults into running code for testing.FragmentContextImpl.getExecutionControls()
FragmentContextInterface.getExecutionControls()
Return the set of execution controls used to inject faults into running code for testing.OperatorContext.getExecutionControls()
QueryContext.getExecutionControls()
Methods in org.apache.drill.exec.ops with parameters of type ExecutionControlsModifier and TypeMethodDescriptionvoid
AccountingDataTunnel.setTestInjectionControls
(ControlsInjector testInjector, ExecutionControls testControls, org.slf4j.Logger testLogger) -
Uses of ExecutionControls in org.apache.drill.exec.rpc.data
Methods in org.apache.drill.exec.rpc.data with parameters of type ExecutionControlsModifier and TypeMethodDescriptionvoid
DataTunnel.setTestInjectionControls
(ControlsInjector testInjector, ExecutionControls testControls, org.slf4j.Logger testLogger) Once a DataTunnel is created, clients of DataTunnel can pass injection controls to enable setting injections at pre-defined places. -
Uses of ExecutionControls in org.apache.drill.exec.testing
Methods in org.apache.drill.exec.testing with parameters of type ExecutionControlsModifier and TypeMethodDescriptionControlsInjector.getLatch
(ExecutionControls executionControls, String desc) Used to insert a latch in site class.ExecutionControlsInjector.getLatch
(ExecutionControls executionControls, String desc) NoOpControlsInjector.getLatch
(ExecutionControls executionControls, String desc) <T extends Throwable>
voidControlsInjector.injectChecked
(ExecutionControls executionControls, String desc, Class<T> exceptionClass) Inject (throw) a checked exception at this point, if an injection is specified, and it is time for it to be thrown.<T extends Throwable>
voidExecutionControlsInjector.injectChecked
(ExecutionControls executionControls, String desc, Class<T> exceptionClass) <T extends Throwable>
voidNoOpControlsInjector.injectChecked
(ExecutionControls executionControls, String desc, Class<T> exceptionClass) void
ControlsInjector.injectInterruptiblePause
(ExecutionControls executionControls, String desc, org.slf4j.Logger logger) Insert a pause that can be interrupted usingThread.interrupt()
at the given site point, if such an injection is specified (i.e.void
ExecutionControlsInjector.injectInterruptiblePause
(ExecutionControls executionControls, String desc, org.slf4j.Logger logger) void
NoOpControlsInjector.injectInterruptiblePause
(ExecutionControls executionControls, String desc, org.slf4j.Logger logger) void
ControlsInjector.injectPause
(ExecutionControls executionControls, String desc, org.slf4j.Logger logger) Pauses at this point, if such an injection is specified (i.e.void
ExecutionControlsInjector.injectPause
(ExecutionControls executionControls, String desc, org.slf4j.Logger logger) void
NoOpControlsInjector.injectPause
(ExecutionControls executionControls, String desc, org.slf4j.Logger logger) void
ControlsInjector.injectUnchecked
(ExecutionControls executionControls, String desc) Inject (throw) an unchecked exception at this point, if an injection is specified, and it is time for it to be thrown.void
ExecutionControlsInjector.injectUnchecked
(ExecutionControls executionControls, String desc) void
NoOpControlsInjector.injectUnchecked
(ExecutionControls executionControls, String desc)