public class PageRankComputation extends BasicComputation<Text,DoubleWritable,Text,DoubleWritable>
Modifier and Type | Field and Description |
---|---|
static String |
DAMPING_FACTOR |
static float |
DAMPING_FACTOR_DEFAULT_VALUE |
static String |
MAX_EPSILON |
Constructor and Description |
---|
PageRankComputation() |
Modifier and Type | Method and Description |
---|---|
void |
compute(Vertex<Text,DoubleWritable,Text> vertex,
Iterable<DoubleWritable> messages) |
addEdgeRequest, addVertexRequest, addVertexRequest, aggregate, getAggregatedValue, getContext, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerContext, initialize, postSuperstep, preSuperstep, removeEdgesRequest, removeVertexRequest, sendMessage, sendMessageToAllEdges, sendMessageToMultipleEdges
getConf, setConf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getConf, setConf
public static final String MAX_EPSILON
public static final String DAMPING_FACTOR
public static final float DAMPING_FACTOR_DEFAULT_VALUE
public void compute(Vertex<Text,DoubleWritable,Text> vertex, Iterable<DoubleWritable> messages) throws IOException
compute
in interface Computation<Text,DoubleWritable,Text,DoubleWritable,DoubleWritable>
compute
in class AbstractComputation<Text,DoubleWritable,Text,DoubleWritable,DoubleWritable>
IOException