org.apache.reef.runtime.yarn.driver.restart

Class DFSEvaluatorPreserver

java.lang.Object

org.apache.reef.runtime.yarn.driver.restart.DFSEvaluatorPreserver

All Implemented Interfaces:

AutoCloseable, EvaluatorPreserver

public final class DFSEvaluatorPreserver
extends Object
implements EvaluatorPreserver, AutoCloseable

An Evaluator Preserver that uses the DFS on YARN.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the writer, which in turn closes the FileSystem.
void	recordAllocatedEvaluator(String id) Adds the allocated evaluator entry to the evaluator log.
void	recordRemovedEvaluator(String id) Adds the removed evaluator entry to the evaluator log.
Set<String>	recoverEvaluators() Recovers the set of evaluators that are alive.

Methods inherited from class java.lang.Object

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

Method Detail

recoverEvaluators

public Set<String> recoverEvaluators()

Recovers the set of evaluators that are alive.

Specified by:

recoverEvaluators in interface EvaluatorPreserver

Returns:

recordAllocatedEvaluator

public void recordAllocatedEvaluator(String id)

Adds the allocated evaluator entry to the evaluator log.

Specified by:

recordAllocatedEvaluator in interface EvaluatorPreserver

Parameters:

id -

recordRemovedEvaluator

public void recordRemovedEvaluator(String id)

Adds the removed evaluator entry to the evaluator log.

Specified by:

recordRemovedEvaluator in interface EvaluatorPreserver

Parameters:

id -

close

public void close()
           throws Exception

Closes the writer, which in turn closes the FileSystem.

Specified by:

close in interface AutoCloseable

Throws:

Exception