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, sendMessageToMultipleEdgesgetConf, setConfclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetConf, setConfpublic 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