co.cask.cdap.test
Interface MapReduceManager

public interface MapReduceManager

Instance for this class is for managing a running MapReduce.

Method Summary

void	stop() Stops the running mapreduce job.
void	waitForFinish(long timeout, TimeUnit timeoutUnit) Blocks until mapreduce job is finished or given timeout is reached

Method Detail

stop

void stop()

Stops the running mapreduce job.

waitForFinish

void waitForFinish(long timeout,
                   TimeUnit timeoutUnit)
                   throws TimeoutException,
                          InterruptedException

Blocks until mapreduce job is finished or given timeout is reached

Parameters:

timeout - amount of time units to wait

timeoutUnit - time unit type

Throws:

TimeoutException - if timeout reached

InterruptedException - if execution is interrupted