Uses of Interface
org.apache.giraph.partition.PartitionOwner

Packages that use PartitionOwner

Package	Description
org.apache.giraph.bsp	Package of generic bulk synchronous processing objects.
org.apache.giraph.comm	Package of communication related objects, IPC service.
org.apache.giraph.comm.netty	Package for netty implementations.
org.apache.giraph.graph	Package of all the graph related objects, built on the org.apache.bsp package.
org.apache.giraph.partition	Package of partitioning related objects.
org.apache.giraph.worker	Package of all the worker related things

Uses of PartitionOwner in org.apache.giraph.bsp

Methods in org.apache.giraph.bsp that return PartitionOwner

Modifier and Type	Method and Description
PartitionOwner	CentralizedServiceWorker.getVertexPartitionOwner(I vertexId) Every client will need to get a partition owner from a vertex id so that they know which worker to sent the request to.

Methods in org.apache.giraph.bsp that return types with arguments of type PartitionOwner

Modifier and Type	Method and Description
Iterable<? extends PartitionOwner>	CentralizedServiceWorker.getPartitionOwners() Get all partition owners.
Collection<? extends PartitionOwner>	CentralizedServiceWorker.startSuperstep() Take all steps prior to actually beginning the computation of a superstep.

Method parameters in org.apache.giraph.bsp with type arguments of type PartitionOwner

Modifier and Type	Method and Description
void	CentralizedServiceWorker.exchangeVertexPartitions(Collection<? extends PartitionOwner> masterSetPartitionOwners) If desired by the user, vertex partitions are redistributed among workers according to the chosen WorkerGraphPartitioner.

Uses of PartitionOwner in org.apache.giraph.comm

Methods in org.apache.giraph.comm that return PartitionOwner

Modifier and Type	Method and Description
PartitionOwner	WorkerClient.getVertexPartitionOwner(I vertexId) Lookup PartitionOwner for a vertex.

Methods in org.apache.giraph.comm with parameters of type PartitionOwner

Modifier and Type	Method and Description
int	SendPartitionCache.addVertex(PartitionOwner partitionOwner, Vertex<I,V,E> vertex) Add a vertex to the cache.
boolean	WorkerClientRequestProcessor.sendVertexRequest(PartitionOwner partitionOwner, Vertex<I,V,E> vertex) Sends a vertex to the appropriate partition owner

Uses of PartitionOwner in org.apache.giraph.comm.netty

Methods in org.apache.giraph.comm.netty that return PartitionOwner

Modifier and Type	Method and Description
PartitionOwner	NettyWorkerClient.getVertexPartitionOwner(I vertexId)

Methods in org.apache.giraph.comm.netty with parameters of type PartitionOwner

Modifier and Type	Method and Description
boolean	NettyWorkerClientRequestProcessor.sendVertexRequest(PartitionOwner partitionOwner, Vertex<I,V,E> vertex)

Uses of PartitionOwner in org.apache.giraph.graph

Methods in org.apache.giraph.graph that return types with arguments of type PartitionOwner

Modifier and Type	Method and Description
Collection<PartitionOwner>	AddressesAndPartitionsWritable.getPartitionOwners() Get partition owners

Methods in org.apache.giraph.graph with parameters of type PartitionOwner

Modifier and Type	Method and Description
<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> void	GiraphTransferRegulator.incrementCounters(PartitionOwner partitionOwner, Vertex<I,V,E> vertex) Increment V & E counts for new vertex read, store values for that outgoing _temporary_ Partition, which shares the Partition ID for the actual remote Partition the collection will eventually be processed in.
boolean	GiraphTransferRegulator.transferThisPartition(PartitionOwner owner) Is this outbound data Collection full, and ready to transfer?

Constructor parameters in org.apache.giraph.graph with type arguments of type PartitionOwner

Constructor and Description
AddressesAndPartitionsWritable(MasterInfo masterInfo, List<WorkerInfo> workerInfos, Collection<PartitionOwner> partitionOwners) Constructor when we want to serialize object

Uses of PartitionOwner in org.apache.giraph.partition

Classes in org.apache.giraph.partition that implement PartitionOwner

Modifier and Type	Class and Description
class	BasicPartitionOwner Basic partition owner, can be subclassed for more complicated partition owner implementations.

Methods in org.apache.giraph.partition that return PartitionOwner

Modifier and Type	Method and Description
PartitionOwner	WorkerGraphPartitionerImpl.createPartitionOwner()
PartitionOwner	WorkerGraphPartitioner.createPartitionOwner() Instantiate the PartitionOwner implementation used to read the master assignments.
PartitionOwner	WorkerGraphPartitionerImpl.getPartitionOwner(I vertexId)
PartitionOwner	WorkerGraphPartitioner.getPartitionOwner(I vertexId) Figure out the owner of a vertex

Methods in org.apache.giraph.partition that return types with arguments of type PartitionOwner

Modifier and Type	Method and Description
static Collection<PartitionOwner>	PartitionBalancer.balancePartitionsAcrossWorkers(org.apache.hadoop.conf.Configuration conf, Collection<PartitionOwner> partitionOwners, Collection<PartitionStats> allPartitionStats, Collection<WorkerInfo> availableWorkerInfos) Balance the partitions with an algorithm based on a value.
Collection<PartitionOwner>	MasterGraphPartitionerImpl.createInitialPartitionOwners(Collection<WorkerInfo> availableWorkerInfos, int maxWorkers)
Collection<PartitionOwner>	MasterGraphPartitioner.createInitialPartitionOwners(Collection<WorkerInfo> availableWorkerInfos, int maxWorkers) Set some initial partition owners for the graph.
Collection<PartitionOwner>	MasterGraphPartitionerImpl.generateChangedPartitionOwners(Collection<PartitionStats> allPartitionStatsList, Collection<WorkerInfo> availableWorkers, int maxWorkers, long superstep)
Collection<PartitionOwner>	MasterGraphPartitioner.generateChangedPartitionOwners(Collection<PartitionStats> allPartitionStatsList, Collection<WorkerInfo> availableWorkers, int maxWorkers, long superstep) After the worker stats have been merged to a single list, the master can use this information to send commands to the workers for any Partition changes.
Collection<PartitionOwner>	MasterGraphPartitionerImpl.getCurrentPartitionOwners()
Collection<PartitionOwner>	MasterGraphPartitioner.getCurrentPartitionOwners() Get current partition owners at this time.
Collection<? extends PartitionOwner>	WorkerGraphPartitionerImpl.getPartitionOwners()
Collection<? extends PartitionOwner>	WorkerGraphPartitioner.getPartitionOwners() Get a collection of the PartitionOwner objects.

Method parameters in org.apache.giraph.partition with type arguments of type PartitionOwner

Modifier and Type	Method and Description
static void	PartitionUtils.analyzePartitionStats(Collection<PartitionOwner> partitionOwnerList, List<PartitionStats> allPartitionStats) Check for imbalances on a per worker basis, by calculating the mean, high and low workers by edges and vertices.
static Collection<PartitionOwner>	PartitionBalancer.balancePartitionsAcrossWorkers(org.apache.hadoop.conf.Configuration conf, Collection<PartitionOwner> partitionOwners, Collection<PartitionStats> allPartitionStats, Collection<WorkerInfo> availableWorkerInfos) Balance the partitions with an algorithm based on a value.
void	MasterGraphPartitionerImpl.setPartitionOwners(Collection<PartitionOwner> partitionOwners)
void	MasterGraphPartitioner.setPartitionOwners(Collection<PartitionOwner> partitionOwners) Sets partition owners for the graph.
static PartitionExchange	PartitionBalancer.updatePartitionOwners(List<PartitionOwner> partitionOwnerList, WorkerInfo myWorkerInfo, Collection<? extends PartitionOwner> masterSetPartitionOwners) Helper function to update partition owners and determine which partitions need to be sent from a specific worker.
static PartitionExchange	PartitionBalancer.updatePartitionOwners(List<PartitionOwner> partitionOwnerList, WorkerInfo myWorkerInfo, Collection<? extends PartitionOwner> masterSetPartitionOwners) Helper function to update partition owners and determine which partitions need to be sent from a specific worker.
PartitionExchange	WorkerGraphPartitionerImpl.updatePartitionOwners(WorkerInfo myWorkerInfo, Collection<? extends PartitionOwner> masterSetPartitionOwners)
PartitionExchange	WorkerGraphPartitioner.updatePartitionOwners(WorkerInfo myWorkerInfo, Collection<? extends PartitionOwner> masterSetPartitionOwners) Get the partitions owners and update locally.

Uses of PartitionOwner in org.apache.giraph.worker

Methods in org.apache.giraph.worker that return PartitionOwner

Modifier and Type	Method and Description
PartitionOwner	BspServiceWorker.getVertexPartitionOwner(I vertexId)

Methods in org.apache.giraph.worker that return types with arguments of type PartitionOwner

Modifier and Type	Method and Description
Iterable<? extends PartitionOwner>	BspServiceWorker.getPartitionOwners()
Collection<? extends PartitionOwner>	BspServiceWorker.startSuperstep()

Method parameters in org.apache.giraph.worker with type arguments of type PartitionOwner

Modifier and Type	Method and Description
void	BspServiceWorker.exchangeVertexPartitions(Collection<? extends PartitionOwner> masterSetPartitionOwners)