public static class VerifyMessage.VerifyMessageComputation extends BasicComputation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.FloatWritable,VerifyMessage.VerifiableMessage>
Modifier and Type | Class and Description |
---|---|
static class |
VerifyMessage.VerifyMessageComputation.VerifyMessageVertexWorkerContext
Worker context used with
VerifyMessage.VerifyMessageComputation . |
Modifier and Type | Field and Description |
---|---|
static String |
SUPERSTEP_COUNT
Dynamically set number of SUPERSTEPS
|
Constructor and Description |
---|
VerifyMessageComputation() |
Modifier and Type | Method and Description |
---|---|
void |
compute(Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.FloatWritable> vertex,
Iterable<VerifyMessage.VerifiableMessage> messages) |
static long |
getFinalSum() |
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 String SUPERSTEP_COUNT
public static long getFinalSum()
public void compute(Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.FloatWritable> vertex, Iterable<VerifyMessage.VerifiableMessage> messages) throws IOException
compute
in interface Computation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.FloatWritable,VerifyMessage.VerifiableMessage,VerifyMessage.VerifiableMessage>
compute
in class AbstractComputation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.FloatWritable,VerifyMessage.VerifiableMessage,VerifyMessage.VerifiableMessage>
IOException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.