org.apache.giraph.io.superstep_output

Interface SuperstepOutput<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Type Parameters:

I - Vertex id

V - Vertex value

E - Edge value

All Known Implementing Classes:

MultiThreadedSuperstepOutput, NoOpSuperstepOutput, SynchronizedSuperstepOutput

public interface SuperstepOutput<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Interface for outputing data during the computation.

Method Summary

Modifier and Type	Method and Description
SimpleVertexWriter<I,V,E>	getVertexWriter() Get the Writer.
void	postApplication() Finalize this output in the end of the application
void	returnVertexWriter(SimpleVertexWriter<I,V,E> vertexWriter) Return the Writer after usage, which you got by calling getVertexWriter()

Method Detail

getVertexWriter

SimpleVertexWriter<I,V,E> getVertexWriter()

Get the Writer. You have to return it after usage in order for it to be properly closed.

Returns:

SimpleVertexWriter

returnVertexWriter

void returnVertexWriter(SimpleVertexWriter<I,V,E> vertexWriter)

Return the Writer after usage, which you got by calling getVertexWriter()

Parameters:

vertexWriter - SimpleVertexWriter which you are returning

postApplication

void postApplication()
              throws IOException,
                     InterruptedException

Finalize this output in the end of the application

Throws:

IOException

InterruptedException