Package com.alibaba.graphscope.example.giraph.circle

Class CircleEdgeInputFormat

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.circle.CircleEdgeInputFormat

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	CircleEdgeInputFormat.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
CircleEdgeInputFormat()

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)

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

CircleEdgeInputFormat

public CircleEdgeInputFormat()

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

Specified by:

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

Throws:

IOException