org.apache.giraph.io.hbase.edgemarker

Class TableEdgeOutputFormat.TableEdgeVertexWriter

java.lang.Object

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

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

org.apache.giraph.io.hbase.HBaseVertexOutputFormat.HBaseVertexWriter<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

org.apache.giraph.io.hbase.edgemarker.TableEdgeOutputFormat.TableEdgeVertexWriter

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:

TableEdgeOutputFormat

public static class TableEdgeOutputFormat.TableEdgeVertexWriter
extends HBaseVertexOutputFormat.HBaseVertexWriter<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Constructor Summary

Constructors

Constructor and Description
TableEdgeVertexWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)

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.hbase.HBaseVertexOutputFormat.HBaseVertexWriter

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

TableEdgeVertexWriter

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

Throws:

IOException

InterruptedException

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