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

Class LiveJournalEdgeInputFormat

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,org.apache.hadoop.io.LongWritable>

com.alibaba.graphscope.example.giraph.format.LiveJournalEdgeInputFormat

All Implemented Interfaces:

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

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	LiveJournalEdgeInputFormat.LiveJournalEdgeReader

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

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

Constructor Summary

Constructors

Constructor	Description
LiveJournalEdgeInputFormat()

Method Summary

Modifier and Type	Method	Description
org.apache.giraph.io.EdgeReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>	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

LiveJournalEdgeInputFormat

public LiveJournalEdgeInputFormat()

Method Detail

createEdgeReader

public org.apache.giraph.io.EdgeReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable> 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,org.apache.hadoop.io.LongWritable>

Parameters:

split - the split to be read

context - the information about the task

Returns:

a new record reader

Throws:

IOException