unipg.gila.partitioning

Class Spinner.ComputeNewPartition

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

org.apache.giraph.worker.WorkerAggregatorDelegator<I,V,E>

org.apache.giraph.graph.AbstractComputation<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue,PartitionMessage,org.apache.hadoop.io.NullWritable>

unipg.gila.partitioning.Spinner.ComputeNewPartition

All Implemented Interfaces:

org.apache.giraph.aggregators.AggregatorUsage, org.apache.giraph.conf.GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue>, org.apache.giraph.conf.TypesHolder<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue,PartitionMessage,org.apache.hadoop.io.NullWritable>, org.apache.giraph.graph.Computation<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue,PartitionMessage,org.apache.hadoop.io.NullWritable>, org.apache.giraph.worker.WorkerAggregatorUsage, org.apache.giraph.worker.WorkerBroadcastUsage, org.apache.giraph.worker.WorkerGlobalCommUsage, org.apache.giraph.worker.WorkerReduceUsage

Enclosing class:

Spinner

public static class Spinner.ComputeNewPartition
extends org.apache.giraph.graph.AbstractComputation<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue,PartitionMessage,org.apache.hadoop.io.NullWritable>

Constructor Summary

Constructors

Constructor and Description
Spinner.ComputeNewPartition()

Method Summary

Methods

Modifier and Type	Method and Description
void	compute(org.apache.giraph.graph.Vertex<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue> vertex, java.lang.Iterable<PartitionMessage> messages)
void	preSuperstep()

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

addEdgeRequest, addVertexRequest, addVertexRequest, getContext, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerContext, initialize, postSuperstep, removeEdgesRequest, removeVertexRequest, sendMessage, sendMessageToAllEdges, sendMessageToMultipleEdges

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

aggregate, getAggregatedValue, getBroadcast, reduce, setWorkerGlobalCommUsage

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.conf.ImmutableClassesGiraphConfigurable

getConf

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

setConf

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

getBroadcast

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

reduce

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

aggregate

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

getAggregatedValue

Constructor Detail

Spinner.ComputeNewPartition

public Spinner.ComputeNewPartition()

Method Detail

compute

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

Specified by:

compute in interface org.apache.giraph.graph.Computation<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue,PartitionMessage,org.apache.hadoop.io.NullWritable>

Specified by:

compute in class org.apache.giraph.graph.AbstractComputation<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue,PartitionMessage,org.apache.hadoop.io.NullWritable>

Throws:

java.io.IOException

preSuperstep

public void preSuperstep()

Specified by:

preSuperstep in interface org.apache.giraph.graph.Computation<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue,PartitionMessage,org.apache.hadoop.io.NullWritable>

Overrides:

preSuperstep in class org.apache.giraph.graph.AbstractComputation<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue,PartitionMessage,org.apache.hadoop.io.NullWritable>