org.apache.giraph.partition

Class HashPartitionerFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

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

org.apache.giraph.partition.GraphPartitionerFactory<I,V,E>

org.apache.giraph.partition.HashPartitionerFactory<I,V,E>

Type Parameters:

I - Vertex id value

V - Vertex value

E - Edge value

All Implemented Interfaces:

GiraphConfigurationSettable<I,V,E>, ImmutableClassesGiraphConfigurable<I,V,E>, GraphPartitionerFactoryInterface<I,V,E>

public class HashPartitionerFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends GraphPartitionerFactory<I,V,E>

Divides the vertices into partitions by their hash code using a simple round-robin hash for great balancing if given a random hash code.

Constructor Summary

Constructors

Constructor and Description
HashPartitionerFactory()

Method Summary

Modifier and Type	Method and Description
int	getPartition(I id, int partitionCount, int workerCount) Calculates in which partition current vertex belongs to, from interval [0, partitionCount).
int	getWorker(int partition, int partitionCount, int workerCount) Calculates worker that should be responsible for passed partition.

Methods inherited from class org.apache.giraph.partition.GraphPartitionerFactory

createMasterGraphPartitioner, createWorkerGraphPartitioner, getPartitionInRange, getPartitionInRange, initialize

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

Constructor Detail

HashPartitionerFactory

public HashPartitionerFactory()

Method Detail

getPartition

public int getPartition(I id,
                        int partitionCount,
                        int workerCount)

Description copied from class: GraphPartitionerFactory

Calculates in which partition current vertex belongs to, from interval [0, partitionCount).

Specified by:

getPartition in class GraphPartitionerFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Parameters:

id - Vertex id

partitionCount - Number of partitions

workerCount - Number of workers

Returns:

partition

getWorker

public int getWorker(int partition,
                     int partitionCount,
                     int workerCount)

Description copied from class: GraphPartitionerFactory

Calculates worker that should be responsible for passed partition.

Specified by:

getWorker in class GraphPartitionerFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Parameters:

partition - Current partition

partitionCount - Number of partitions

workerCount - Number of workers

Returns:

index of worker responsible for current partition