org.apache.giraph.io.formats.multi

Class MultiInputUtils

java.lang.Object

org.apache.giraph.io.formats.multi.MultiInputUtils

public class MultiInputUtils
extends Object

Utility methods used by MultiVertexInputFormat and MultiEdgeInputFormat

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getSplits

public static List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context,
                                                                     int minSplitCountHint,
                                                                     List<? extends GiraphInputFormat> inputFormats)
                                                              throws IOException,
                                                                     InterruptedException

Get the list of input splits for all formats.

Parameters:

context - The job context

minSplitCountHint - Minimum number of splits to create (hint)

inputFormats - List of input formats

Returns:

The list of input splits

Throws:

IOException

InterruptedException

writeInputSplit

public static void writeInputSplit(org.apache.hadoop.mapreduce.InputSplit inputSplit,
                                   DataOutput dataOutput,
                                   List<? extends GiraphInputFormat> inputFormats)
                            throws IOException

Write input split info to DataOutput. Input split belongs to one of the formats.

Parameters:

inputSplit - InputSplit

dataOutput - DataOutput

inputFormats - List of input formats

Throws:

IOException

readInputSplit

public static org.apache.hadoop.mapreduce.InputSplit readInputSplit(DataInput dataInput,
                                                                    List<? extends GiraphInputFormat> inputFormats)
                                                             throws IOException,
                                                                    ClassNotFoundException

Read input split info from DataInput. Input split belongs to one of the formats.

Parameters:

dataInput - DataInput

inputFormats - List of input formats

Returns:

InputSplit

Throws:

IOException

ClassNotFoundException