I
- Vertex idV
- Vertex dataE
- Edge datapublic abstract class GiraphInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> extends DefaultImmutableClassesGiraphConfigurable<I,V,E>
VertexInputFormat
and EdgeInputFormat
.Constructor and Description |
---|
GiraphInputFormat() |
Modifier and Type | Method and Description |
---|---|
abstract void |
checkInputSpecs(org.apache.hadoop.conf.Configuration conf)
Check that input is valid.
|
abstract List<org.apache.hadoop.mapreduce.InputSplit> |
getSplits(org.apache.hadoop.mapreduce.JobContext context,
int minSplitCountHint)
Get the list of input splits for the format.
|
org.apache.hadoop.mapreduce.InputSplit |
readInputSplit(DataInput dataInput)
Read input split info from DataInput.
|
void |
writeInputSplit(org.apache.hadoop.mapreduce.InputSplit inputSplit,
DataOutput dataOutput)
Write input split info to DataOutput.
|
getConf, setConf
public abstract void checkInputSpecs(org.apache.hadoop.conf.Configuration conf)
conf
- Configurationpublic abstract List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context, int minSplitCountHint) throws IOException, InterruptedException
context
- The job contextminSplitCountHint
- Minimum number of splits to create (hint)IOException
InterruptedException
public void writeInputSplit(org.apache.hadoop.mapreduce.InputSplit inputSplit, DataOutput dataOutput) throws IOException
inputSplit
- InputSplitdataOutput
- DataOutputIOException
public org.apache.hadoop.mapreduce.InputSplit readInputSplit(DataInput dataInput) throws IOException, ClassNotFoundException
dataInput
- DataInputIOException
ClassNotFoundException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.