org.apache.giraph.io.hbase.edgemarker

Class TableEdgeInputFormat

java.lang.Object

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

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

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

org.apache.giraph.io.hbase.HBaseVertexInputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

org.apache.giraph.io.hbase.edgemarker.TableEdgeInputFormat

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>

public class TableEdgeInputFormat
extends HBaseVertexInputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Test subclass for HBaseVertexInputFormat. Reads a simple children qualifier to create an edge.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TableEdgeInputFormat.TableEdgeVertexReader Uses the RecordReader to return Hbase rows

Nested classes/interfaces inherited from class org.apache.giraph.io.hbase.HBaseVertexInputFormat

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

Field Summary

Fields inherited from class org.apache.giraph.io.hbase.HBaseVertexInputFormat

BASE_FORMAT

Constructor Summary

Constructors

Constructor and Description
TableEdgeInputFormat()

Method Summary

Modifier and Type	Method and Description
void	checkInputSpecs(org.apache.hadoop.conf.Configuration conf)
VertexReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>	createVertexReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)

Methods inherited from class org.apache.giraph.io.hbase.HBaseVertexInputFormat

getSplits

Methods inherited from class org.apache.giraph.io.GiraphInputFormat

readInputSplit, writeInputSplit

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

TableEdgeInputFormat

public TableEdgeInputFormat()

Method Detail

checkInputSpecs

public void checkInputSpecs(org.apache.hadoop.conf.Configuration conf)

Specified by:

checkInputSpecs in class GiraphInputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

createVertexReader

public VertexReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> createVertexReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                                                                      org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                                                               throws IOException

Specified by:

createVertexReader in class VertexInputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Throws:

IOException