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

Interface DFSEvaluatorLogWriter

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

DFSEvaluatorLogAppendWriter, DFSEvaluatorLogOverwriteWriter

public interface DFSEvaluatorLogWriter
extends AutoCloseable

The Evaluator log writer that writes to DFS. Currently supports regular append and append by overwrite. Actual log entries should be immutable and no entry should ever be deleted. To remove an evaluator, a removal entry should be preferred.

Method Summary

Methods

Modifier and Type	Method and Description
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