public class AggregatorsTestComputation 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 |
AggregatorsTestComputation.AggregatorsTestMasterCompute
Master compute which uses aggregators.
|
static class |
AggregatorsTestComputation.SimpleEdgeInputFormat
Simple VertexInputFormat
|
static class |
AggregatorsTestComputation.SimpleEdgeReader
Simple Edge Reader
|
static class |
AggregatorsTestComputation.SimpleVertexInputFormat
Simple VertexInputFormat
|
static class |
AggregatorsTestComputation.SimpleVertexReader
Simple VertexReader
|
Constructor and Description |
---|
AggregatorsTestComputation() |
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)
Must be defined by user to do computation on a single Vertex.
|
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 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
AbstractComputation
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>
vertex
- Vertexmessages
- Messages that were sent to this vertex in the previous
superstep. Each message is only guaranteed to have
a life expectancy as long as next() is not called.IOException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.