org.apache.reef.tests.watcher

Class WatcherTestTask

java.lang.Object

org.apache.reef.tests.watcher.WatcherTestTask

All Implemented Interfaces:

Task, TaskMessageSource

public final class WatcherTestTask
extends Object
implements Task, TaskMessageSource

Task for WatcherTest.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	WatcherTestTask.TaskSuspendedHandler Handler for SuspendEvent.

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	call(byte[] memento) Called by the resourcemanager harness to execute the task.
Optional<TaskMessage>	getMessage()

Methods inherited from class java.lang.Object

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

Method Detail

call

public byte[] call(byte[] memento)
            throws Exception

Description copied from interface: Task

Called by the resourcemanager harness to execute the task.

Specified by:

call in interface Task

Parameters:

memento - the memento objected passed down by the driver.

Returns:

the user defined return value

Throws:

Exception - whenever the Task encounters an unsolved issue. This Exception will be thrown at the Driver's event handler.

getMessage

public Optional<TaskMessage> getMessage()

Specified by:

getMessage in interface TaskMessageSource

Returns:

a message to be sent back to the Driver, or Optional.empty() if no message shall be sent at this time.