co.cask.cdap.test
Interface SparkManager

public interface SparkManager

Instance for this class is for managing a running Spark.

Method Summary

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

Method Detail

stop

void stop()

Stops the running spark job.

waitForFinish

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

Blocks until spark 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