org.apache.giraph.io.superstep_output

Class MultiThreadedSuperstepOutput<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.io.superstep_output.MultiThreadedSuperstepOutput<I,V,E>

Type Parameters:

I - Vertex id

V - Vertex value

E - Edge value

All Implemented Interfaces:

SuperstepOutput<I,V,E>

public class MultiThreadedSuperstepOutput<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends Object
implements SuperstepOutput<I,V,E>

Class to use as SuperstepOutput when chosen VertexOutputFormat is thread-safe.

Constructor Summary

Constructors

Constructor and Description
MultiThreadedSuperstepOutput(ImmutableClassesGiraphConfiguration<I,V,E> conf, org.apache.hadoop.mapreduce.Mapper.Context context) Constructor

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 SuperstepOutput.getVertexWriter()

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiThreadedSuperstepOutput

public MultiThreadedSuperstepOutput(ImmutableClassesGiraphConfiguration<I,V,E> conf,
                                    org.apache.hadoop.mapreduce.Mapper.Context context)

Constructor

Parameters:

conf - Configuration

context - Mapper context

Method Detail

getVertexWriter

public SimpleVertexWriter<I,V,E> getVertexWriter()

Description copied from interface: SuperstepOutput

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

Specified by:

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

Returns:

SimpleVertexWriter

returnVertexWriter

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

Description copied from interface: SuperstepOutput

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

Specified by:

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

Parameters:

vertexWriter - SimpleVertexWriter which you are returning

postApplication

public void postApplication()
                     throws IOException,
                            InterruptedException

Description copied from interface: SuperstepOutput

Finalize this output in the end of the application

Specified by:

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

Throws:

IOException

InterruptedException