org.apache.reef.tests

Class TestDriverLauncher

java.lang.Object

org.apache.reef.tests.TestDriverLauncher

public final class TestDriverLauncher
extends Object

A launcher for REEF Drivers. It behaves exactly like the original DriverLauncher, but does not dump the exception stack trace to the log. (it writes only a short INFO message). It is used in TestFailDriver etc. unit tests.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
static TestDriverLauncher	getLauncher(Configuration runtimeConfiguration) Instantiate a launcher for the given Configuration.
LauncherStatus	run(Configuration driverConfig) Run a job.
LauncherStatus	run(Configuration driverConfig, long timeOut) Run a job with a waiting timeout after which it will be killed, if it did not complete yet.
String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

getLauncher

public static TestDriverLauncher getLauncher(Configuration runtimeConfiguration)
                                      throws BindException,
                                             InjectionException

Instantiate a launcher for the given Configuration.

Parameters:

runtimeConfiguration - the resourcemanager configuration to be used

Returns:

a DriverLauncher based on the given resourcemanager configuration

Throws:

BindException - on configuration errors

InjectionException - on configuration errors

close

public void close()

run

public LauncherStatus run(Configuration driverConfig)

Run a job. Waits indefinitely for the job to complete.

Parameters:

driverConfig - the configuration for the driver. See DriverConfiguration for details.

Returns:

the state of the job after execution.

run

public LauncherStatus run(Configuration driverConfig,
                 long timeOut)

Run a job with a waiting timeout after which it will be killed, if it did not complete yet.

Parameters:

driverConfig - the configuration for the driver. See DriverConfiguration for details.

timeOut - timeout on the job.

Returns:

the state of the job after execution.

toString

public String toString()

Overrides:

toString in class Object