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

Interface DFSEvaluatorLogReaderWriter

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

DFSEvaluatorLogAppendReaderWriter, DFSEvaluatorLogOverwriteReaderWriter

public interface DFSEvaluatorLogReaderWriter
extends AutoCloseable

The Evaluator log reader/writer that reads from and writes to the Hadoop DFS. Currently supports regular append and append by overwrite.

Method Summary

Methods

Modifier and Type	Method and Description
CloseableIterable<String>	readFromEvaluatorLog() Reads a formatted entry (addition or removal) from the DFS evaluator log.
void	writeToEvaluatorLog(String formattedEntry) Writes a formatted entry (addition or removal) for an Evaluator ID into the DFS evaluator log.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

writeToEvaluatorLog

void writeToEvaluatorLog(String formattedEntry)
                         throws IOException

Writes a formatted entry (addition or removal) for an Evaluator ID into the DFS evaluator log.

Parameters:

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

Throws:

IOException

readFromEvaluatorLog

CloseableIterable<String> readFromEvaluatorLog()
                                               throws IOException

Reads a formatted entry (addition or removal) from the DFS evaluator log.

Returns:

the formatted entry.

Throws:

IOException