Package com.alibaba.graphscope.example.giraph

Class SSSP

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.SSSP

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 SSSP
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>

Demonstrates the basic Pregel shortest paths implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SSSP.SimpleSuperstepVertexOutputFormat	Simple VertexOutputFormat.
static class	SSSP.SSSPWorkerContext

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.giraph.conf.LongConfOption	SOURCE_ID	The shortest paths id

Constructor Summary

Constructors

Constructor	Description
SSSP()

Method Summary

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)

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

SOURCE_ID

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

The shortest paths id

Constructor Detail

SSSP

public SSSP()

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

Throws:

IOException