org.apache.giraph.io.accumulo.edgemarker

Class AccumuloEdgeOutputFormat.AccumuloEdgeVertexWriter

java.lang.Object

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

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

org.apache.giraph.io.accumulo.AccumuloVertexOutputFormat.AccumuloVertexWriter<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

org.apache.giraph.io.accumulo.edgemarker.AccumuloEdgeOutputFormat.AccumuloEdgeVertexWriter

All Implemented Interfaces:

GiraphConfigurationSettable<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>, SimpleVertexWriter<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Enclosing class:

AccumuloEdgeOutputFormat

public static class AccumuloEdgeOutputFormat.AccumuloEdgeVertexWriter
extends AccumuloVertexOutputFormat.AccumuloVertexWriter<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Constructor Summary

Constructors

Constructor and Description
AccumuloEdgeVertexWriter(org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation> writer, String tableName)

Method Summary

Modifier and Type	Method and Description
void	writeVertex(Vertex<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> vertex)

Methods inherited from class org.apache.giraph.io.accumulo.AccumuloVertexOutputFormat.AccumuloVertexWriter

close, getContext, getRecordWriter, initialize

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

AccumuloEdgeVertexWriter

public AccumuloEdgeVertexWriter(org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation> writer,
                                String tableName)

Method Detail

writeVertex

public void writeVertex(Vertex<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> vertex)
                 throws IOException,
                        InterruptedException

Throws:

IOException

InterruptedException