org.apache.giraph.partition

Class PartitionExchange

java.lang.Object

org.apache.giraph.partition.PartitionExchange

public class PartitionExchange
extends Object

Describes what is required to send and wait for in a potential partition exchange between workers.

Constructor Summary

Constructors

Constructor and Description
PartitionExchange(Set<WorkerInfo> myDependencyWorkerSet, Map<WorkerInfo,List<Integer>> sendWorkerPartitionMap) Only constructor.

Method Summary

Modifier and Type	Method and Description
boolean	doExchange() Is this worker involved in a partition exchange? Receiving or sending?
Set<WorkerInfo>	getMyDependencyWorkerSet() Get the workers that I must wait for
Map<WorkerInfo,List<Integer>>	getSendWorkerPartitionMap() Get a mapping of worker to list of partition ids I need to send to.

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionExchange

public PartitionExchange(Set<WorkerInfo> myDependencyWorkerSet,
                         Map<WorkerInfo,List<Integer>> sendWorkerPartitionMap)

Only constructor.

Parameters:

myDependencyWorkerSet - All the workers I must wait for

sendWorkerPartitionMap - Partitions I need to send to other workers

Method Detail

getMyDependencyWorkerSet

public Set<WorkerInfo> getMyDependencyWorkerSet()

Get the workers that I must wait for

Returns:

Set of workers I must wait for

getSendWorkerPartitionMap

public Map<WorkerInfo,List<Integer>> getSendWorkerPartitionMap()

Get a mapping of worker to list of partition ids I need to send to.

Returns:

Mapping of worker to partition id list I will send to.

doExchange

public boolean doExchange()

Is this worker involved in a partition exchange? Receiving or sending?

Returns:

True if needs to be involved in the exchange, false otherwise.