public static class SimpleSuperstepVertex.SimpleSuperstepVertexReader extends GeneratedVertexReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.FloatWritable>
SimpleSuperstepVertexDEAFULT_REVERSE_ID_ORDER, DEFAULT_READER_VERTICES, inputSplit, READER_VERTICES, recordsRead, REVERSE_ID_ORDER, reverseIdOrder, totalRecords| Constructor and Description |
|---|
SimpleSuperstepVertex.SimpleSuperstepVertexReader() |
| Modifier and Type | Method and Description |
|---|---|
Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.Writable> |
getCurrentVertex()
Get the current vertex.
|
boolean |
nextVertex() |
close, getProgress, initializegetConf, setConfpublic SimpleSuperstepVertex.SimpleSuperstepVertexReader()
public boolean nextVertex()
throws IOException,
InterruptedException
nextVertex in class VertexReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.FloatWritable>IOExceptionInterruptedExceptionpublic Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.Writable> getCurrentVertex() throws IOException, InterruptedException
VertexReadergetCurrentVertex in class VertexReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.FloatWritable>IOExceptionInterruptedExceptionCopyright © 2011-2013 The Apache Software Foundation. All Rights Reserved.