public static class SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation extends MigrationAbstractComputation.MigrationFullBasicComputation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable>
MigrationAbstractComputation.MigrationBasicComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable>, MigrationAbstractComputation.MigrationFullAbstractComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable>, MigrationAbstractComputation.MigrationFullBasicComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable>
Modifier and Type | Field and Description |
---|---|
static String |
SMC_AGG
Aggregator to get values from the master to the workers
|
Constructor and Description |
---|
SimpleMigrationMasterComputation() |
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) |
getSuperstep
addEdgeRequest, addVertexRequest, addVertexRequest, getTotalNumEdges, getTotalNumVertices, getWorkerContext, postSuperstep, preSuperstep, readFields, removeEdgesRequest, removeVertexRequest, sendMessage, sendMessageToAllEdges, sendMessageToMultipleEdges, write
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
public static final String SMC_AGG
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
compute
in class MigrationAbstractComputation<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>
IOException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.