org.apache.reef.runtime.common.driver

Interface EvaluatorPreserver

All Known Implementing Classes:

DFSEvaluatorPreserver

public interface EvaluatorPreserver

A interface to preserve evaluators across driver restarts.

Method Summary

Methods

Modifier and Type	Method and Description
void	recordAllocatedEvaluator(String id) Called when an evaluator is to be preserved.
void	recordRemovedEvaluator(String id) Called when an evaluator is to be removed.
Set<String>	recoverEvaluators() Called on driver restart when evaluators are to be recovered.

Method Detail

recoverEvaluators

Set<String> recoverEvaluators()

Called on driver restart when evaluators are to be recovered.

recordAllocatedEvaluator

void recordAllocatedEvaluator(String id)

Called when an evaluator is to be preserved.

recordRemovedEvaluator

void recordRemovedEvaluator(String id)

Called when an evaluator is to be removed.

Parameters:

id -