unipg.gila.io

Class LayoutInputFormat.JSONPartitionedLongArrayFloatVertexReader

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.LayoutInputFormat.JSONPartitionedLongArrayFloatVertexReader

All Implemented Interfaces:

org.apache.giraph.aggregators.AggregatorUsage, org.apache.giraph.conf.GiraphConfigurationSettable<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable>, org.apache.giraph.worker.WorkerAggregatorUsage, org.apache.giraph.worker.WorkerBroadcastUsage, org.apache.giraph.worker.WorkerGlobalCommUsage, org.apache.giraph.worker.WorkerReduceUsage

Enclosing class:

LayoutInputFormat

protected class LayoutInputFormat.JSONPartitionedLongArrayFloatVertexReader
extends org.apache.giraph.io.VertexReader<I,V,E>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	LayoutInputFormat.JSONPartitionedLongArrayFloatVertexReader()

Method Summary

Methods

Modifier and Type	Method and Description
protected java.lang.Iterable<org.apache.giraph.edge.Edge<PartitionedLongWritable,org.apache.hadoop.io.NullWritable>>	getEdges(org.json.JSONArray jsonVertex)
protected PartitionedLongWritable	getId(org.json.JSONArray jsonVertex)
protected CoordinateWritable	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

LayoutInputFormat.JSONPartitionedLongArrayFloatVertexReader

protected LayoutInputFormat.JSONPartitionedLongArrayFloatVertexReader()

Method Detail

getEdges

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

Throws:

org.json.JSONException

java.io.IOException

getId

protected PartitionedLongWritable getId(org.json.JSONArray jsonVertex)
                                 throws org.json.JSONException,
                                        java.io.IOException

Throws:

org.json.JSONException

java.io.IOException

getValue

protected CoordinateWritable 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