I
- Vertex idV
- Vertex valuepublic abstract class VertexValueInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable> extends VertexInputFormat<I,V,org.apache.hadoop.io.Writable>
EdgeInputFormat
.Constructor and Description |
---|
VertexValueInputFormat() |
Modifier and Type | Method and Description |
---|---|
VertexReader<I,V,org.apache.hadoop.io.Writable> |
createVertexReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
Create a vertex reader for a given split.
|
abstract VertexValueReader<I,V> |
createVertexValueReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
Create a
VertexValueReader for a given split. |
checkInputSpecs, getSplits, readInputSplit, writeInputSplit
getConf, setConf
public abstract VertexValueReader<I,V> createVertexValueReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
VertexValueReader
for a given split. The framework will
call VertexValueReader.initialize(InputSplit,
TaskAttemptContext)
before the split is used.split
- The split to be readcontext
- The information about the taskIOException
public final VertexReader<I,V,org.apache.hadoop.io.Writable> createVertexReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
VertexInputFormat
VertexReader.initialize(InputSplit, TaskAttemptContext)
before
the split is used.createVertexReader
in class VertexInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
split
- the split to be readcontext
- the information about the taskIOException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.