org.apache.giraph.io.gora

Class GoraVertexOutputFormat.GoraVertexWriter

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

org.apache.giraph.io.VertexWriter<I,V,E>

org.apache.giraph.io.gora.GoraVertexOutputFormat.GoraVertexWriter

All Implemented Interfaces:

GiraphConfigurationSettable<I,V,E>, ImmutableClassesGiraphConfigurable<I,V,E>, SimpleVertexWriter<I,V,E>, org.apache.zookeeper.Watcher

Direct Known Subclasses:

GoraGVertexVertexOutputFormat.GoraGVertexVertexWriter

Enclosing class:

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

protected abstract class GoraVertexOutputFormat.GoraVertexWriter
extends VertexWriter<I,V,E>
implements org.apache.zookeeper.Watcher

Abstract class to be implemented by the user based on their specific vertex/edges output. Easiest to ignore the key value separator and only use key instead.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher

org.apache.zookeeper.Watcher.Event

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GoraVertexWriter()

Method Summary

Modifier and Type	Method and Description
void	close(org.apache.hadoop.mapreduce.TaskAttemptContext context) Close this VertexWriter to future operations.
protected abstract Object	getGoraKey(Vertex<I,V,E> vertex) Gets the correct key from a computed vertex.
protected abstract org.apache.gora.persistency.Persistent	getGoraVertex(Vertex<I,V,E> vertex) Each vertex needs to be transformed into a Gora object to be sent to a specific data store.
void	initialize(org.apache.hadoop.mapreduce.TaskAttemptContext context) Use the context to setup writing the vertices.
void	process(org.apache.zookeeper.WatchedEvent event)
void	writeVertex(Vertex<I,V,E> vertex) Writes the next vertex and associated data

Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

getConf, setConf

Methods inherited from class java.lang.Object

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

Constructor Detail

GoraVertexWriter

protected GoraVertexWriter()

Method Detail

initialize

public void initialize(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                throws IOException,
                       InterruptedException

Description copied from class: VertexWriter

Use the context to setup writing the vertices. Guaranteed to be called prior to any other function.

Specified by:

initialize in class VertexWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Parameters:

context - Context used to write the vertices.

Throws:

IOException

InterruptedException

close

public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
           throws IOException,
                  InterruptedException

Description copied from class: VertexWriter

Close this VertexWriter to future operations.

Specified by:

close in class VertexWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Parameters:

context - the context of the task

Throws:

IOException

InterruptedException

writeVertex

public void writeVertex(Vertex<I,V,E> vertex)
                 throws IOException,
                        InterruptedException

Description copied from interface: SimpleVertexWriter

Writes the next vertex and associated data

Specified by:

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

Parameters:

vertex - set the properties of this vertex

Throws:

IOException

InterruptedException

process

public void process(org.apache.zookeeper.WatchedEvent event)

Specified by:

process in interface org.apache.zookeeper.Watcher

getGoraVertex

protected abstract org.apache.gora.persistency.Persistent getGoraVertex(Vertex<I,V,E> vertex)

Each vertex needs to be transformed into a Gora object to be sent to a specific data store.

Parameters:

vertex - vertex to be transformed into a Gora object

Returns:

Gora representation of the vertex

getGoraKey

protected abstract Object getGoraKey(Vertex<I,V,E> vertex)

Gets the correct key from a computed vertex.

Parameters:

vertex - vertex to extract the key from.

Returns:

The key representing such vertex