public class PageRankWithKryoSimpleWritable extends BasicComputation<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue,PageRankWithKryoSimpleWritable.MessageValue>
Modifier and Type | Class and Description |
---|---|
static class |
PageRankWithKryoSimpleWritable.DoubleMaxWrapperAggregator
Aggregator for getting max double value
|
static class |
PageRankWithKryoSimpleWritable.DoubleMinWrapperAggregator
Aggregator for getting min double value.
|
static class |
PageRankWithKryoSimpleWritable.EdgeValue
Creating a custom edge value class to force kryo to
register with a new ID.
|
static class |
PageRankWithKryoSimpleWritable.MessageValue
Creating a custom message value class to force kryo to
register with a new ID.
|
static class |
PageRankWithKryoSimpleWritable.PageRankWithKryoMasterCompute
Master compute associated with
PageRankWithKryoSimpleWritable . |
static class |
PageRankWithKryoSimpleWritable.PageRankWithKryoVertexInputFormat
VertexInputFormat that supports
PageRankWithKryoSimpleWritable |
static class |
PageRankWithKryoSimpleWritable.PageRankWithKryoVertexReader
Simple VertexReader that supports
PageRankWithKryoSimpleWritable |
static class |
PageRankWithKryoSimpleWritable.PageRankWithKryoWorkerContext
Worker context used with
PageRankWithKryoSimpleWritable . |
static class |
PageRankWithKryoSimpleWritable.VertexValue
Creating a custom vertex value class to force kryo to
register with a new ID.
|
Modifier and Type | Field and Description |
---|---|
static int |
MAX_SUPERSTEPS
Number of supersteps for this test
|
Constructor and Description |
---|
PageRankWithKryoSimpleWritable() |
Modifier and Type | Method and Description |
---|---|
void |
compute(Vertex<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue> vertex,
Iterable<PageRankWithKryoSimpleWritable.MessageValue> 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,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue> vertex, Iterable<PageRankWithKryoSimpleWritable.MessageValue> messages) throws IOException
compute
in interface Computation<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue,PageRankWithKryoSimpleWritable.MessageValue,PageRankWithKryoSimpleWritable.MessageValue>
compute
in class AbstractComputation<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue,PageRankWithKryoSimpleWritable.MessageValue,PageRankWithKryoSimpleWritable.MessageValue>
IOException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.