I
- Vertex idV
- Vertex dataE
- Edge datapublic abstract class VertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> extends WorkerAggregatorDelegator<I,V,E>
Constructor and Description |
---|
VertexReader() |
Modifier and Type | Method and Description |
---|---|
abstract void |
close()
Close this
VertexReader to future operations. |
abstract Vertex<I,V,E> |
getCurrentVertex()
Get the current vertex.
|
abstract float |
getProgress()
How much of the input has the
VertexReader consumed i.e. |
abstract void |
initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
Use the input split and context to setup reading the vertices.
|
abstract boolean |
nextVertex() |
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
public abstract void initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
inputSplit
- Input split to be used for reading vertices.context
- Context from the task.IOException
InterruptedException
public abstract boolean nextVertex() throws IOException, InterruptedException
IOException
InterruptedException
public abstract Vertex<I,V,E> getCurrentVertex() throws IOException, InterruptedException
IOException
InterruptedException
public abstract void close() throws IOException
VertexReader
to future operations.IOException
public abstract float getProgress() throws IOException, InterruptedException
VertexReader
consumed i.e.
has been processed by?0.0
to 1.0
.IOException
InterruptedException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.