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