org.apache.giraph.io.formats.multi

Class EdgeInputFormatDescription<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.io.formats.multi.InputFormatDescription<EdgeInputFormat<I,E>>

org.apache.giraph.io.formats.multi.EdgeInputFormatDescription<I,E>

Type Parameters:

I - Vertex id

E - Edge data

public class EdgeInputFormatDescription<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
extends InputFormatDescription<EdgeInputFormat<I,E>>

Description of the edge input format - holds edge input format class and all parameters specifically set for that edge input format. Used only with MultiEdgeInputFormat

Field Summary

Fields

Modifier and Type	Field and Description
static StrConfOption	EDGE_INPUT_FORMAT_DESCRIPTIONS EdgeInputFormats description - JSON array containing a JSON array for each edge input.

Constructor Summary

Constructors

Constructor and Description
EdgeInputFormatDescription(Class<? extends EdgeInputFormat<I,E>> edgeInputFormatClass) Constructor with edge input format class
EdgeInputFormatDescription(String description) Constructor with json string describing this input format

Method Summary

Modifier and Type	Method and Description
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> List<EdgeInputFormat<I,E>>	createEdgeInputFormats(ImmutableClassesGiraphConfiguration<I,org.apache.hadoop.io.Writable,E> conf) Create all edge input formats
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> List<EdgeInputFormatDescription<I,E>>	getEdgeInputFormatDescriptions(org.apache.hadoop.conf.Configuration conf) Get descriptions of edge input formats from configuration.

Methods inherited from class org.apache.giraph.io.formats.multi.InputFormatDescription

addParameter, addParameters, getInputFormatClass, putParametersToConfiguration, setInputFormatClass, toJsonArray, toJsonString, toString

Methods inherited from class java.lang.Object

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

Field Detail

EDGE_INPUT_FORMAT_DESCRIPTIONS

public static final StrConfOption EDGE_INPUT_FORMAT_DESCRIPTIONS

EdgeInputFormats description - JSON array containing a JSON array for each edge input. Edge input JSON arrays contain one or two elements - first one is the name of edge input class, and second one is JSON object with all specific parameters for this edge input. For example: [["EIF1",{"p":"v1"}],["EIF2",{"p":"v2","q":"v"}]]

Constructor Detail

EdgeInputFormatDescription

public EdgeInputFormatDescription(Class<? extends EdgeInputFormat<I,E>> edgeInputFormatClass)

Constructor with edge input format class

Parameters:

edgeInputFormatClass - Edge input format class

EdgeInputFormatDescription

public EdgeInputFormatDescription(String description)

Constructor with json string describing this input format

Parameters:

description - Json string describing this input format

Method Detail

getEdgeInputFormatDescriptions

public static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> List<EdgeInputFormatDescription<I,E>> getEdgeInputFormatDescriptions(org.apache.hadoop.conf.Configuration conf)

Get descriptions of edge input formats from configuration.

Type Parameters:

I - Vertex id

E - Edge data

Parameters:

conf - Configuration

Returns:

List of edge input format descriptions

createEdgeInputFormats

public static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> List<EdgeInputFormat<I,E>> createEdgeInputFormats(ImmutableClassesGiraphConfiguration<I,org.apache.hadoop.io.Writable,E> conf)

Create all edge input formats

Type Parameters:

I - Vertex id

E - Edge data

Parameters:

conf - Configuration

Returns:

List with all edge input formats