Package com.alibaba.graphscope.example.giraph.format

Class P2PEdgeMultipleLongInputFormat

java.lang.Object

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

org.apache.giraph.io.GiraphInputFormat<I,org.apache.hadoop.io.Writable,E>

org.apache.giraph.io.EdgeInputFormat<I,E>

org.apache.giraph.io.formats.TextEdgeInputFormat<org.apache.hadoop.io.LongWritable,MultipleLongWritable>

com.alibaba.graphscope.example.giraph.format.P2PEdgeMultipleLongInputFormat

All Implemented Interfaces:

org.apache.giraph.conf.GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,MultipleLongWritable>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,MultipleLongWritable>

public class P2PEdgeMultipleLongInputFormat
extends TextEdgeInputFormat<org.apache.hadoop.io.LongWritable,MultipleLongWritable>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	P2PEdgeMultipleLongInputFormat.P2PEdgeReader

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

TextEdgeInputFormat.TextEdgeReader, TextEdgeInputFormat.TextEdgeReaderFromEachLine, TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed<T>

Constructor Summary

Constructors

Constructor	Description
P2PEdgeMultipleLongInputFormat()

Method Summary

Modifier and Type	Method	Description
org.apache.giraph.io.EdgeReader<org.apache.hadoop.io.LongWritable,MultipleLongWritable>	createEdgeReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)	Create an edge reader for a given split.

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

checkInputSpecs, getSplits

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

readInputSplit, writeInputSplit

Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

getConf, setConf

Methods inherited from class java.lang.Object

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

Constructor Detail

P2PEdgeMultipleLongInputFormat

public P2PEdgeMultipleLongInputFormat()

Method Detail

createEdgeReader

public org.apache.giraph.io.EdgeReader<org.apache.hadoop.io.LongWritable,MultipleLongWritable> createEdgeReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                                                                      org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                                                               throws IOException

Create an edge reader for a given split. The framework will call EdgeReader.initialize(InputSplit, TaskAttemptContext) before the split is used.

Specified by:

createEdgeReader in class org.apache.giraph.io.EdgeInputFormat<org.apache.hadoop.io.LongWritable,MultipleLongWritable>

Parameters:

split - the split to be read

context - the information about the task

Returns:

a new record reader

Throws:

IOException