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

Class DFSEvaluatorLogOverwriteWriter

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, DFSEvaluatorLogWriter

public final class DFSEvaluatorLogOverwriteWriter
extends Object
implements DFSEvaluatorLogWriter

The DFS evaluator logger that does not support append and does append by overwrite. dfs.support.append should be false.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the FileSystem.
void	writeToEvaluatorLog(String formattedEntry) Writes a formatted entry (addition or removal) for an Evaluator ID into the DFS evaluator log.

Methods inherited from class java.lang.Object

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

Method Detail

writeToEvaluatorLog

public void writeToEvaluatorLog(String formattedEntry)
                         throws IOException

Writes a formatted entry (addition or removal) for an Evaluator ID into the DFS evaluator log. The log is appended to by reading first, adding on the information, and then overwriting the entire log.

Specified by:

writeToEvaluatorLog in interface DFSEvaluatorLogWriter

Parameters:

formattedEntry - The formatted entry (entry with evaluator ID and addition/removal information).

Throws:

IOException - when file cannot be written.

close

public void close()
           throws Exception

Closes the FileSystem.

Specified by:

close in interface AutoCloseable

Throws:

Exception