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

Class LiveJournalVertexInputFormat

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

com.alibaba.graphscope.example.giraph.format.LiveJournalVertexInputFormat

All Implemented Interfaces:

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

public class LiveJournalVertexInputFormat
extends TextVertexInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	LiveJournalVertexInputFormat.LiveJournalVertexReader

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>

Constructor Summary

Constructors

Constructor	Description
LiveJournalVertexInputFormat()

Method Summary

Modifier and Type	Method	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.

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 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

LiveJournalVertexInputFormat

public LiveJournalVertexInputFormat()

Method Detail

createVertexReader

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

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

Parameters:

split - the split to be read

context - the information about the task

Returns:

the text vertex reader to be used

Throws:

IOException