org.apache.giraph.io.hbase

Class HBaseVertexOutputFormat.HBaseVertexWriter<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.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

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

org.apache.giraph.io.hbase.HBaseVertexOutputFormat.HBaseVertexWriter<I,V,E>

Type Parameters:

I - Vertex index value

V - Vertex value

E - Edge value

All Implemented Interfaces:

GiraphConfigurationSettable<I,V,E>, ImmutableClassesGiraphConfigurable<I,V,E>, SimpleVertexWriter<I,V,E>

Enclosing class:

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

public abstract static class HBaseVertexOutputFormat.HBaseVertexWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends VertexWriter<I,V,E>

Constructor Simple class which takes an instance of RecordWriter over Writable objects. Subclasses are expected to implement writeVertex()

Constructor Summary

Constructors

Constructor and Description
HBaseVertexWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) Sets up base table output format and creates a record writer.

Method Summary

Modifier and Type	Method and Description
void	close(org.apache.hadoop.mapreduce.TaskAttemptContext context) close
org.apache.hadoop.mapreduce.TaskAttemptContext	getContext() getContext
org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.io.Writable>	getRecordWriter() Get the table record writer;
void	initialize(org.apache.hadoop.mapreduce.TaskAttemptContext context) 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

Methods inherited from interface org.apache.giraph.io.SimpleVertexWriter

writeVertex

Constructor Detail

HBaseVertexWriter

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

Sets up base table output format and creates a record writer.

Parameters:

context - task attempt context

Throws:

IOException

InterruptedException

Method Detail

initialize

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

initialize

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

close

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

close

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

getRecordWriter

public org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.io.Writable> getRecordWriter()

Get the table record writer;

Returns:

Record writer to be used for writing.

getContext

public org.apache.hadoop.mapreduce.TaskAttemptContext getContext()

getContext

Returns:

Context passed to initialize.