Package org.apache.wayang.giraph.Algorithm

Class PageRankAlgorithm.PageRankVertexInputFormat

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

org.apache.wayang.giraph.Algorithm.PageRankAlgorithm.PageRankVertexInputFormat

All Implemented Interfaces:

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

Enclosing class:

PageRankAlgorithm

public static class PageRankAlgorithm.PageRankVertexInputFormat
extends org.apache.giraph.io.formats.GeneratedVertexInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>

Simple VertexInputFormat that supports PageRankAlgorithm

Constructor Summary

Constructors

Constructor	Description
PageRankVertexInputFormat()

Method Summary

Modifier and Type	Method	Description
org.apache.giraph.io.VertexReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>	createVertexReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)

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

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

PageRankVertexInputFormat

public PageRankVertexInputFormat()

Method Detail

createVertexReader

public org.apache.giraph.io.VertexReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> createVertexReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                                                                                                                                  org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                                                                                                                           throws java.io.IOException

Specified by:

createVertexReader in class org.apache.giraph.io.VertexInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>

Throws:

java.io.IOException