protected class PartitioningInputFormat.PartitioningVertexReader
extends org.apache.giraph.io.VertexReader<I,V,E>
Modifier | Constructor and Description |
---|---|
protected |
PartitioningInputFormat.PartitioningVertexReader() |
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) |
aggregate, getAggregatedValue, getBroadcast, reduce, setWorkerGlobalCommUsage
protected PartitioningInputFormat.PartitioningVertexReader()
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
org.json.JSONException
java.io.IOException
protected org.apache.hadoop.io.LongWritable getId(org.json.JSONArray jsonVertex) throws org.json.JSONException, java.io.IOException
org.json.JSONException
java.io.IOException
protected PartitioningVertexValue getValue(org.json.JSONArray jsonVertex) throws org.json.JSONException, java.io.IOException
org.json.JSONException
java.io.IOException
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) throws org.json.JSONException
org.json.JSONException