I
- Vertex idV
- Vertex datapublic abstract class BasicVertexValueReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable> extends VertexReader<I,V,org.apache.hadoop.io.Writable>
Constructor and Description |
---|
BasicVertexValueReader() |
Modifier and Type | Method and Description |
---|---|
abstract I |
getCurrentVertexId()
User-defined method to extract the vertex id.
|
abstract V |
getCurrentVertexValue()
User-defined method to extract the vertex value.
|
close, getCurrentVertex, getProgress, initialize, nextVertex
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
public abstract I getCurrentVertexId() throws IOException, InterruptedException
IOException
InterruptedException
public abstract V getCurrentVertexValue() throws IOException, InterruptedException
IOException
InterruptedException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.