public class SimplePageRankComputation extends BasicComputation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable>
Modifier and Type | Class and Description |
---|---|
static class |
SimplePageRankComputation.SimplePageRankMasterCompute
Master compute associated with
SimplePageRankComputation . |
static class |
SimplePageRankComputation.SimplePageRankVertexInputFormat
Simple VertexInputFormat that supports
SimplePageRankComputation |
static class |
SimplePageRankComputation.SimplePageRankVertexOutputFormat
Simple VertexOutputFormat that supports
SimplePageRankComputation |
static class |
SimplePageRankComputation.SimplePageRankVertexReader
Simple VertexReader that supports
SimplePageRankComputation |
static class |
SimplePageRankComputation.SimplePageRankWorkerContext
Worker context used with
SimplePageRankComputation . |
Modifier and Type | Field and Description |
---|---|
static int |
MAX_SUPERSTEPS
Number of supersteps for this test
|
Constructor and Description |
---|
SimplePageRankComputation() |
Modifier and Type | Method and Description |
---|---|
void |
compute(Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> vertex,
Iterable<org.apache.hadoop.io.DoubleWritable> messages) |
addEdgeRequest, addVertexRequest, addVertexRequest, getContext, getMyWorkerIndex, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerContext, getWorkerCount, getWorkerForVertex, initialize, postSuperstep, preSuperstep, removeEdgesRequest, removeVertexRequest, sendMessage, sendMessageToAllEdges, sendMessageToMultipleEdges
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getConf
setConf
getBroadcast
reduce, reduceMerge
aggregate
getAggregatedValue
public static final int MAX_SUPERSTEPS
public void compute(Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> vertex, Iterable<org.apache.hadoop.io.DoubleWritable> messages) throws IOException
compute
in interface Computation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>
compute
in class AbstractComputation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>
IOException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.