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 TypeMethodDescriptionvoidAccountingDataTunnel.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 TypeMethodDescriptionvoidDataTunnel.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) voidControlsInjector.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.voidExecutionControlsInjector.injectInterruptiblePause(ExecutionControls executionControls, String desc, org.slf4j.Logger logger) voidNoOpControlsInjector.injectInterruptiblePause(ExecutionControls executionControls, String desc, org.slf4j.Logger logger) voidControlsInjector.injectPause(ExecutionControls executionControls, String desc, org.slf4j.Logger logger) Pauses at this point, if such an injection is specified (i.e.voidExecutionControlsInjector.injectPause(ExecutionControls executionControls, String desc, org.slf4j.Logger logger) voidNoOpControlsInjector.injectPause(ExecutionControls executionControls, String desc, org.slf4j.Logger logger) voidControlsInjector.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.voidExecutionControlsInjector.injectUnchecked(ExecutionControls executionControls, String desc) voidNoOpControlsInjector.injectUnchecked(ExecutionControls executionControls, String desc)