public class MultiInputUtils extends Object
MultiVertexInputFormat
and
MultiEdgeInputFormat
Modifier and Type | Method and Description |
---|---|
static List<org.apache.hadoop.mapreduce.InputSplit> |
getSplits(org.apache.hadoop.mapreduce.JobContext context,
int minSplitCountHint,
List<? extends GiraphInputFormat> inputFormats)
Get the list of input splits for all formats.
|
static org.apache.hadoop.mapreduce.InputSplit |
readInputSplit(DataInput dataInput,
List<? extends GiraphInputFormat> inputFormats)
Read input split info from DataInput.
|
static void |
writeInputSplit(org.apache.hadoop.mapreduce.InputSplit inputSplit,
DataOutput dataOutput,
List<? extends GiraphInputFormat> inputFormats)
Write input split info to DataOutput.
|
public static List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context, int minSplitCountHint, List<? extends GiraphInputFormat> inputFormats) throws IOException, InterruptedException
context
- The job contextminSplitCountHint
- Minimum number of splits to create (hint)inputFormats
- List of input formatsIOException
InterruptedException
public static void writeInputSplit(org.apache.hadoop.mapreduce.InputSplit inputSplit, DataOutput dataOutput, List<? extends GiraphInputFormat> inputFormats) throws IOException
inputSplit
- InputSplitdataOutput
- DataOutputinputFormats
- List of input formatsIOException
public static org.apache.hadoop.mapreduce.InputSplit readInputSplit(DataInput dataInput, List<? extends GiraphInputFormat> inputFormats) throws IOException, ClassNotFoundException
dataInput
- DataInputinputFormats
- List of input formatsIOException
ClassNotFoundException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.