org.apache.giraph.io.accumulo

Class AccumuloVertexInputFormat.AccumuloVertexReader<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.worker.WorkerAggregatorDelegator<I,V,E>

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

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

Type Parameters:

I - vertex id type

V - vertex value type

E - edge type

All Implemented Interfaces:

AggregatorUsage, GiraphConfigurationSettable<I,V,E>, ImmutableClassesGiraphConfigurable<I,V,E>, WorkerAggregatorUsage, WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerReduceUsage

Enclosing class:

AccumuloVertexInputFormat<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 AccumuloVertexInputFormat.AccumuloVertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends VertexReader<I,V,E>

Abstract class which provides a template for instantiating vertices from Accumulo Key/Value pairs.

Constructor Summary

Constructors

Constructor and Description
AccumuloVertexReader(org.apache.hadoop.mapreduce.RecordReader<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> reader) Constructor used to pass Record Reader instance

Method Summary

Modifier and Type	Method and Description
void	close() close
ImmutableClassesGiraphConfiguration<I,V,E>	getConfiguration()
protected org.apache.hadoop.mapreduce.TaskAttemptContext	getContext() getContext
float	getProgress() getProgress
protected org.apache.hadoop.mapreduce.RecordReader<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>	getRecordReader() Get the result record reader
void	initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext context) initialize the reader.

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

getCurrentVertex, nextVertex

Methods inherited from class org.apache.giraph.worker.WorkerAggregatorDelegator

aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage

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

AccumuloVertexReader

public AccumuloVertexReader(org.apache.hadoop.mapreduce.RecordReader<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> reader)

Constructor used to pass Record Reader instance

Parameters:

reader - Accumulo record reader

Method Detail

getConfiguration

public ImmutableClassesGiraphConfiguration<I,V,E> getConfiguration()

initialize

public void initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit,
                       org.apache.hadoop.mapreduce.TaskAttemptContext context)
                throws IOException,
                       InterruptedException

initialize the reader.

Specified by:

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

Parameters:

inputSplit - Input split to be used for reading vertices.

context - Context from the task.

Throws:

IOException

InterruptedException

close

public void close()
           throws IOException

close

Specified by:

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

Throws:

IOException

getProgress

public float getProgress()
                  throws IOException,
                         InterruptedException

getProgress

Specified by:

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

Returns:

progress

Throws:

IOException

InterruptedException

getRecordReader

protected org.apache.hadoop.mapreduce.RecordReader<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> getRecordReader()

Get the result record reader

Returns:

Record reader to be used for reading.

getContext

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

getContext

Returns:

Context passed to initialize.