I
- Vertex idV
- Vertex valuepublic abstract class VertexValueReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable> extends BasicVertexValueReader<I,V>
VertexValueInputFormat
.Constructor and Description |
---|
VertexValueReader() |
Modifier and Type | Method and Description |
---|---|
Vertex<I,V,org.apache.hadoop.io.Writable> |
getCurrentVertex()
Get the current vertex.
|
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.
|
getCurrentVertexId, getCurrentVertexValue
close, getProgress, nextVertex
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
public void initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
VertexReader
initialize
in class VertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
inputSplit
- Input split to be used for reading vertices.context
- Context from the task.IOException
InterruptedException
public final Vertex<I,V,org.apache.hadoop.io.Writable> getCurrentVertex() throws IOException, InterruptedException
VertexReader
getCurrentVertex
in class VertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
IOException
InterruptedException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.