Uses of Class
org.apache.drill.exec.testing.ExecutionControls
Package
Description
-
Uses of ExecutionControls in org.apache.drill.exec.ops
Modifier 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()
Modifier and TypeMethodDescriptionvoid
AccountingDataTunnel.setTestInjectionControls
(ControlsInjector testInjector, ExecutionControls testControls, org.slf4j.Logger testLogger) -
Uses of ExecutionControls in org.apache.drill.exec.rpc.data
Modifier 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
Modifier 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)