org.apache.giraph.examples

Class NormalizingLongDoubleDoubleTextInputFormat

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

org.apache.giraph.io.GiraphInputFormat<I,V,E>

org.apache.giraph.io.VertexInputFormat<I,V,E>

org.apache.giraph.io.formats.TextVertexInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>

org.apache.giraph.examples.NormalizingLongDoubleDoubleTextInputFormat

All Implemented Interfaces:

GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>

public class NormalizingLongDoubleDoubleTextInputFormat
extends TextVertexInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>
implements ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>

Simple text-based VertexInputFormat for unweighted graphs with long ids. Each line consists of: vertex neighbor1:weight1 neighbor2:weight2 ...

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	NormalizingLongDoubleDoubleTextInputFormat.NormalizingLongDoubleDoubleDoubleVertexReader Vertex reader associated with LongDoubleDoubleTextInputFormat.

Nested classes/interfaces inherited from class org.apache.giraph.io.formats.TextVertexInputFormat

TextVertexInputFormat.TextVertexReader, TextVertexInputFormat.TextVertexReaderFromEachLine, TextVertexInputFormat.TextVertexReaderFromEachLineProcessed<T>, TextVertexInputFormat.TextVertexReaderFromEachLineProcessedHandlingExceptions<T,X extends Throwable>

Field Summary

Fields inherited from class org.apache.giraph.io.formats.TextVertexInputFormat

textInputFormat

Constructor Summary

Constructors

Constructor and Description
NormalizingLongDoubleDoubleTextInputFormat()

Method Summary

Modifier and Type	Method and Description
TextVertexInputFormat.TextVertexReader	createVertexReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) The factory method which produces the TextVertexInputFormat.TextVertexReader used by this input format.
ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>	getConf() Return the configuration used by this object.
void	setConf(ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable> configuration) Set the configuration to be used by this object.

Methods inherited from class org.apache.giraph.io.formats.TextVertexInputFormat

checkInputSpecs, getSplits

Methods inherited from class org.apache.giraph.io.GiraphInputFormat

readInputSplit, writeInputSplit

Methods inherited from class java.lang.Object

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

Constructor Detail

NormalizingLongDoubleDoubleTextInputFormat

public NormalizingLongDoubleDoubleTextInputFormat()

Method Detail

createVertexReader

public TextVertexInputFormat.TextVertexReader createVertexReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                 org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                          throws IOException

Description copied from class: TextVertexInputFormat

The factory method which produces the TextVertexInputFormat.TextVertexReader used by this input format.

Specified by:

createVertexReader in class TextVertexInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>

Parameters:

split - the split to be read

context - the information about the task

Returns:

the text vertex reader to be used

Throws:

IOException

setConf

public void setConf(ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable> configuration)

Description copied from interface: GiraphConfigurationSettable

Set the configuration to be used by this object.

Specified by:

setConf in interface GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>

Overrides:

setConf in class DefaultImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>

Parameters:

configuration - Set configuration

getConf

public ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable> getConf()

Description copied from interface: ImmutableClassesGiraphConfigurable

Return the configuration used by this object.

Specified by:

getConf in interface ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>

Overrides:

getConf in class DefaultImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>

Returns:

Set configuration