unipg.gila.io

Class PartitioningInputFormat.PartitioningVertexReader

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>

unipg.gila.io.PartitioningInputFormat.PartitioningVertexReader

All Implemented Interfaces:

org.apache.giraph.aggregators.AggregatorUsage, org.apache.giraph.conf.GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue>, org.apache.giraph.worker.WorkerAggregatorUsage, org.apache.giraph.worker.WorkerBroadcastUsage, org.apache.giraph.worker.WorkerGlobalCommUsage, org.apache.giraph.worker.WorkerReduceUsage

Enclosing class:

PartitioningInputFormat

protected class PartitioningInputFormat.PartitioningVertexReader
extends org.apache.giraph.io.VertexReader<I,V,E>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PartitioningInputFormat.PartitioningVertexReader()

Method Summary

Methods

Modifier and Type	Method and Description
protected java.lang.Iterable<org.apache.giraph.edge.Edge<org.apache.hadoop.io.LongWritable,EdgeValue>>	getEdges(org.json.JSONArray jsonVertex)
protected org.apache.hadoop.io.LongWritable	getId(org.json.JSONArray jsonVertex)
protected PartitioningVertexValue	getValue(org.json.JSONArray jsonVertex)
protected org.apache.giraph.graph.Vertex<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.FloatWritable>	handleException(org.apache.hadoop.io.Text line, org.json.JSONArray jsonVertex, java.lang.Exception e)
protected org.json.JSONArray	preprocessLine(org.apache.hadoop.io.Text line)

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

aggregate, getAggregatedValue, getBroadcast, reduce, 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

PartitioningInputFormat.PartitioningVertexReader

protected PartitioningInputFormat.PartitioningVertexReader()

Method Detail

getEdges

protected java.lang.Iterable<org.apache.giraph.edge.Edge<org.apache.hadoop.io.LongWritable,EdgeValue>> getEdges(org.json.JSONArray jsonVertex)
                                                                                                         throws org.json.JSONException,
                                                                                                                java.io.IOException

Throws:

org.json.JSONException

java.io.IOException

getId

protected org.apache.hadoop.io.LongWritable getId(org.json.JSONArray jsonVertex)
                                           throws org.json.JSONException,
                                                  java.io.IOException

Throws:

org.json.JSONException

java.io.IOException

getValue

protected PartitioningVertexValue getValue(org.json.JSONArray jsonVertex)
                                    throws org.json.JSONException,
                                           java.io.IOException

Throws:

org.json.JSONException

java.io.IOException

handleException

protected org.apache.giraph.graph.Vertex<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.FloatWritable> handleException(org.apache.hadoop.io.Text line,
                                                                                                                            org.json.JSONArray jsonVertex,
                                                                                                                            java.lang.Exception e)

preprocessLine

protected org.json.JSONArray preprocessLine(org.apache.hadoop.io.Text line)
                                     throws org.json.JSONException

Throws:

org.json.JSONException