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

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.