I
- vertexId typeV
- vertexValue typeE
- edgeValue typeB
- mappingTarget typepublic abstract class MappingInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,B extends org.apache.hadoop.io.Writable> extends GiraphInputFormat<I,V,E>
DefaultImmutableClassesGiraphConfigurable.setConf(org.apache.giraph.conf.ImmutableClassesGiraphConfiguration)
.Constructor and Description |
---|
MappingInputFormat() |
Modifier and Type | Method and Description |
---|---|
abstract MappingReader<I,V,E,B> |
createMappingReader(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 MappingReader<I,V,E,B> createMappingReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
VertexReader.initialize(InputSplit,
org.apache.hadoop.mapreduce.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.