java.lang.Object
- org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>
- - org.apache.giraph.worker.WorkerAggregatorDelegator<OID_T,VDATA_T,EDATA_T>
  - - org.apache.giraph.graph.AbstractComputation<I,V,E,M,M>
    - - org.apache.giraph.graph.BasicComputation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>
      - com.alibaba.graphscope.example.giraph.MessageApp

All Implemented Interfaces:

org.apache.giraph.aggregators.AggregatorUsage, org.apache.giraph.conf.GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>, org.apache.giraph.conf.TypesHolder<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>, org.apache.giraph.graph.Computation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>, org.apache.giraph.worker.WorkerAggregatorUsage, org.apache.giraph.worker.WorkerBroadcastUsage, org.apache.giraph.worker.WorkerGlobalCommUsage, org.apache.giraph.worker.WorkerIndexUsage<org.apache.hadoop.io.LongWritable>, org.apache.giraph.worker.WorkerReduceUsage
```
public class MessageApp
extends org.apache.giraph.graph.BasicComputation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>
```
Only send msg.

Field Summary

Fields
Modifier and Type Field Description

static org.apache.giraph.conf.LongConfOption MAX_SUPER_STEP

Constructor Summary

Constructors
Constructor Description

MessageApp()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`compute(org.apache.giraph.graph.Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable> vertex, Iterable<org.apache.hadoop.io.LongWritable> messages)`	Must be defined by user to do computation on a single Vertex.

Methods inherited from class org.apache.giraph.graph.AbstractComputation
addEdgeRequest, addVertexRequest, addVertexRequest, getContext, getMyWorkerIndex, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerContext, getWorkerCount, getWorkerForVertex, incStep, initialize, postSuperstep, preSuperstep, removeEdgesRequest, removeVertexRequest, sendMessage, sendMessageToAllEdges, sendMessageToMultipleEdges, setFragment, setGiraphMessageManager, setWorkerContext

Methods inherited from class org.apache.giraph.worker.WorkerAggregatorDelegator
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setAggregatorManager

Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable
getConf, setConf

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.giraph.aggregators.AggregatorUsage
getAggregatedValue

Methods inherited from interface org.apache.giraph.conf.GiraphConfigurationSettable
setConf

Methods inherited from interface org.apache.giraph.conf.ImmutableClassesGiraphConfigurable
getConf

Methods inherited from interface org.apache.giraph.worker.WorkerAggregatorUsage
aggregate

Methods inherited from interface org.apache.giraph.worker.WorkerBroadcastUsage
getBroadcast

Methods inherited from interface org.apache.giraph.worker.WorkerReduceUsage
reduce, reduceMerge

Field Detail

MAX_SUPER_STEP

public static org.apache.giraph.conf.LongConfOption MAX_SUPER_STEP

Constructor Detail
- MessageApp
```
public MessageApp()
```

Method Detail

compute

public void compute(org.apache.giraph.graph.Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable> vertex,
                    Iterable<org.apache.hadoop.io.LongWritable> messages)
             throws IOException

Must be defined by user to do computation on a single Vertex.

Parameters:: vertex - Vertex; messages - Messages that were sent to this vertex in the previous superstep. Each message is only guaranteed to have
Throws:: IOException

Class MessageApp

Field Summary

Constructor Summary

Method Summary

Methods inherited from class org.apache.giraph.graph.AbstractComputation

Methods inherited from class org.apache.giraph.worker.WorkerAggregatorDelegator

Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

Methods inherited from class java.lang.Object

Methods inherited from interface org.apache.giraph.aggregators.AggregatorUsage

Methods inherited from interface org.apache.giraph.conf.GiraphConfigurationSettable

Methods inherited from interface org.apache.giraph.conf.ImmutableClassesGiraphConfigurable

Methods inherited from interface org.apache.giraph.worker.WorkerAggregatorUsage

Methods inherited from interface org.apache.giraph.worker.WorkerBroadcastUsage

Methods inherited from interface org.apache.giraph.worker.WorkerReduceUsage

Field Detail

MAX_SUPER_STEP

Constructor Detail

MessageApp

Method Detail

compute