org.apache.giraph.io.accumulo

Class AccumuloVertexInputFormat<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.GiraphInputFormat<I,V,E>

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

org.apache.giraph.io.accumulo.AccumuloVertexInputFormat<I,V,E>

Type Parameters:

I - vertex id type

V - vertex value type

E - edge type

All Implemented Interfaces:

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

public abstract class AccumuloVertexInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends VertexInputFormat<I,V,E>

Class which wraps the AccumuloInputFormat. It's designed as an extension point to VertexInputFormat subclasses who wish to read from AccumuloTables. Works with AccumuloVertexOutputFormat

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AccumuloVertexInputFormat.AccumuloVertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> Abstract class which provides a template for instantiating vertices from Accumulo Key/Value pairs.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat	accumuloInputFormat delegate input format for all accumulo operations.

Constructor Summary

Constructors

Constructor and Description
AccumuloVertexInputFormat()

Method Summary

Modifier and Type	Method and Description
List<org.apache.hadoop.mapreduce.InputSplit>	getSplits(org.apache.hadoop.mapreduce.JobContext context, int minSplitCountHint) Get the list of input splits for the format.

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

createVertexReader

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

checkInputSpecs, 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

Field Detail

accumuloInputFormat

protected org.apache.accumulo.core.client.mapreduce.AccumuloInputFormat accumuloInputFormat

delegate input format for all accumulo operations.

Constructor Detail

AccumuloVertexInputFormat

public AccumuloVertexInputFormat()

Method Detail

getSplits

public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context,
                                                              int minSplitCountHint)
                                                       throws IOException,
                                                              InterruptedException

Description copied from class: GiraphInputFormat

Get the list of input splits for the format.

Specified by:

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

Parameters:

context - The job context

minSplitCountHint - Minimum number of splits to create (hint)

Returns:

The list of input splits

Throws:

IOException

InterruptedException