org.apache.giraph.graph

Class ComputeCallable<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>

java.lang.Object

org.apache.giraph.graph.ComputeCallable<I,V,E,M1,M2>

Type Parameters:

I - Vertex index value

V - Vertex value

E - Edge value

M1 - Incoming message type

M2 - Outgoing message type

All Implemented Interfaces:

Callable<Collection<PartitionStats>>

public class ComputeCallable<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>
extends Object
implements Callable<Collection<PartitionStats>>

Compute as many vertex partitions as possible. Every thread will has its own instance of WorkerClientRequestProcessor to send requests. Note that the partition ids are used in the partitionIdQueue rather than the actual partitions since that would cause the partitions to be loaded into memory when using the out-of-core graph partition store. We should only load on demand.

Constructor Summary

Constructors

Constructor and Description
ComputeCallable(org.apache.hadoop.mapreduce.Mapper.Context context, GraphState graphState, MessageStore<I,M1> messageStore, ImmutableClassesGiraphConfiguration<I,V,E> configuration, CentralizedServiceWorker<I,V,E> serviceWorker) Constructor

Method Summary

Modifier and Type	Method and Description
Collection<PartitionStats>	call()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ComputeCallable

public ComputeCallable(org.apache.hadoop.mapreduce.Mapper.Context context,
                       GraphState graphState,
                       MessageStore<I,M1> messageStore,
                       ImmutableClassesGiraphConfiguration<I,V,E> configuration,
                       CentralizedServiceWorker<I,V,E> serviceWorker)

Constructor

Parameters:

context - Context

graphState - Current graph state (use to create own graph state)

messageStore - Message store

configuration - Configuration

serviceWorker - Service worker

Method Detail

call

public Collection<PartitionStats> call()

Specified by:

call in interface Callable<Collection<PartitionStats>>