Package org.apache.drill.exec.testing

Class Injection

java.lang.Object

org.apache.drill.exec.testing.Injection

Direct Known Subclasses:

CountDownLatchInjectionImpl, ExceptionInjection, PauseInjection

public abstract class Injection
extends Object

The base class for all types of injections (currently, pause and exception).

Field Summary

Fields

Modifier and Type	Field	Description
protected final String	address
protected final String	desc
protected final int	port
protected final Class<?>	siteClass

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Injection(String address, int port, String siteClass, String desc, int nSkip, int nFire, long msPause)

Method Summary

Modifier and Type	Method	Description
String	getDesc()
long	getMsPause()
Class<?>	getSiteClass()
protected boolean	injectNow()	This function checks if it is the right time for the injection to happen.
final boolean	isValidForBit(CoordinationProtos.DrillbitEndpoint endpoint)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

address

protected final String address

port

protected final int port

siteClass

protected final Class<?> siteClass

desc

protected final String desc

Constructor Details

Injection

protected Injection(String address,
 int port,
 String siteClass,
 String desc,
 int nSkip,
 int nFire,
 long msPause)
             throws InjectionConfigurationException

Throws:

InjectionConfigurationException

Method Details

injectNow

protected boolean injectNow()

This function checks if it is the right time for the injection to happen.

Returns:

if the injection should be injected now

getDesc

public String getDesc()

getSiteClass

public Class<?> getSiteClass()

isValidForBit

public final boolean isValidForBit(CoordinationProtos.DrillbitEndpoint endpoint)

getMsPause

public long getMsPause()

toString

public String toString()

Overrides:

toString in class Object