I
- Vertex idV
- Vertex dataE
- Edge datapublic class MultiVertexInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> extends VertexInputFormat<I,V,E>
Constructor and Description |
---|
MultiVertexInputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
checkInputSpecs(org.apache.hadoop.conf.Configuration conf)
Check that input is valid.
|
VertexReader<I,V,E> |
createVertexReader(org.apache.hadoop.mapreduce.InputSplit inputSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
Create a vertex reader for a given split.
|
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 |
setConf(ImmutableClassesGiraphConfiguration<I,V,E> conf)
Set the configuration to be used by this object.
|
void |
writeInputSplit(org.apache.hadoop.mapreduce.InputSplit inputSplit,
DataOutput dataOutput)
Write input split info to DataOutput.
|
getConf
public void checkInputSpecs(org.apache.hadoop.conf.Configuration conf)
GiraphInputFormat
checkInputSpecs
in class GiraphInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
conf
- Configurationpublic void setConf(ImmutableClassesGiraphConfiguration<I,V,E> conf)
GiraphConfigurationSettable
setConf
in interface GiraphConfigurationSettable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
setConf
in class DefaultImmutableClassesGiraphConfigurable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
conf
- Set configurationpublic VertexReader<I,V,E> createVertexReader(org.apache.hadoop.mapreduce.InputSplit inputSplit, 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,E extends org.apache.hadoop.io.Writable>
inputSplit
- the split to be readcontext
- the information about the taskIOException
public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context, int minSplitCountHint) throws IOException, InterruptedException
GiraphInputFormat
getSplits
in class GiraphInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
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
GiraphInputFormat
writeInputSplit
in class GiraphInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
inputSplit
- InputSplitdataOutput
- DataOutputIOException
public org.apache.hadoop.mapreduce.InputSplit readInputSplit(DataInput dataInput) throws IOException, ClassNotFoundException
GiraphInputFormat
readInputSplit
in class GiraphInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
dataInput
- DataInputIOException
ClassNotFoundException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.