org.apache.reef.task

Interface TaskMessageSource

All Known Implementing Classes:

NoopTask, SuspendTestTask, TaskMessagingTask

public interface TaskMessageSource

Message source for control flow messages from a task to the Driver.

The getMessage() method in an Implementation of this interface will be called by the Evaluator resourcemanager whenever it is about to communicate with the Driver anyway. Hence, this can be used for occasional status updates etc.

Method Summary

Methods

Modifier and Type	Method and Description
Optional<TaskMessage>	getMessage()

Method Detail

getMessage

Optional<TaskMessage> getMessage()

Returns:

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