org.apache.giraph.io.accumulo.edgemarker

Class AccumuloEdgeInputFormat.AccumuloEdgeVertexReader

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<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

org.apache.giraph.io.accumulo.edgemarker.AccumuloEdgeInputFormat.AccumuloEdgeVertexReader

All Implemented Interfaces:

AggregatorUsage, 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>, WorkerAggregatorUsage, WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerReduceUsage

Enclosing class:

AccumuloEdgeInputFormat

public static class AccumuloEdgeInputFormat.AccumuloEdgeVertexReader
extends AccumuloVertexInputFormat.AccumuloVertexReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Field Summary

Fields

Modifier and Type	Field and Description
static Pattern	commaPattern

Constructor Summary

Constructors

Constructor and Description
AccumuloEdgeVertexReader(org.apache.hadoop.mapreduce.RecordReader<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> recordReader)

Method Summary

Modifier and Type	Method and Description
Vertex<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>	getCurrentVertex()
boolean	nextVertex()

Methods inherited from class org.apache.giraph.io.accumulo.AccumuloVertexInputFormat.AccumuloVertexReader

close, getConfiguration, getContext, getProgress, getRecordReader, initialize

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

Field Detail

commaPattern

public static final Pattern commaPattern

Constructor Detail

AccumuloEdgeVertexReader

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

Method Detail

nextVertex

public boolean nextVertex()
                   throws IOException,
                          InterruptedException

Specified by:

nextVertex in class VertexReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Throws:

IOException

InterruptedException

getCurrentVertex

public Vertex<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> getCurrentVertex()
                                                                                                       throws IOException,
                                                                                                              InterruptedException

Specified by:

getCurrentVertex in class VertexReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Throws:

IOException

InterruptedException