Package org.apache.drill.exec.testing

Class PauseInjection

java.lang.Object

org.apache.drill.exec.testing.Injection

org.apache.drill.exec.testing.PauseInjection

public class PauseInjection
extends Injection

Injection for a single pause. Pause indefinitely until signalled. This class is used internally for tracking injected pauses. Note that pauses can be fired only once; nFire field is ignored. These pauses are specified via ExecConstants.DRILLBIT_CONTROL_INJECTIONS session option. After the pauses are set, the user sends another signal to unpause all the pauses. This triggers the Foreman to 1) unpause all pauses in QueryContext, and 2) send an unpause signal to all fragments, each of which unpauses all pauses in FragmentContext.

Field Summary

Fields inherited from class org.apache.drill.exec.testing.Injection

address, desc, port, siteClass

Method Summary

Modifier and Type	Method	Description
void	interruptiblePause()
void	pause()	Pause indefinitely, unless a duration exists
void	unpause()

Methods inherited from class org.apache.drill.exec.testing.Injection

getDesc, getMsPause, getSiteClass, injectNow, isValidForBit, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Details

pause

public void pause()

Pause indefinitely, unless a duration exists

interruptiblePause

public void interruptiblePause()
                        throws InterruptedException

Throws:

InterruptedException

unpause

public void unpause()