org.apache.reef.examples.suspend

Class SuspendTestTask

java.lang.Object

org.apache.reef.examples.suspend.SuspendTestTask

All Implemented Interfaces:

Task, TaskMessageSource

public class SuspendTestTask
extends Object
implements Task, TaskMessageSource

Simple do-nothing task that can send messages to the Driver and can be suspended/resumed.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SuspendTestTask.SuspendHandler Handler for suspend event.

Constructor Summary

Constructors

Constructor and Description
SuspendTestTask(CheckpointService checkpointService, int numCycles, int delay) Task constructor: invoked by TANG.

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	call(byte[] memento) Main method of the task: run cycle from 0 to numCycles, and sleep for delay seconds on each cycle.
Optional<TaskMessage>	getMessage() Update driver on current state of the task.

Methods inherited from class java.lang.Object

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

Constructor Detail

SuspendTestTask

@Inject
public SuspendTestTask(CheckpointService checkpointService,
                      int numCycles,
                      int delay)

Task constructor: invoked by TANG.

Parameters:

numCycles - number of cycles to run in the task.

delay - delay in seconds between cycles in the task.

Method Detail

call

public byte[] call(byte[] memento)
            throws IOException,
                   InterruptedException

Main method of the task: run cycle from 0 to numCycles, and sleep for delay seconds on each cycle.

Specified by:

call in interface Task

Parameters:

memento - serialized version of the counter. Empty array for initial run, but can contain value for resumed job.

Returns:

serialized version of the counter.

Throws:

IOException

InterruptedException

getMessage

public Optional<TaskMessage> getMessage()

Update driver on current state of the task.

Specified by:

getMessage in interface TaskMessageSource

Returns:

serialized version of the counter.