org.apache.giraph.partition

Class HashRangePartitionerFactory<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.HashRangePartitionerFactory<I,V,E>

Type Parameters:

I - Vertex index value

V - Vertex value

E - Edge value

All Implemented Interfaces:

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

public class HashRangePartitionerFactory<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 ranges of the hash space.

Constructor Summary

Constructors

Constructor and Description
HashRangePartitionerFactory()

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

HashRangePartitionerFactory

public HashRangePartitionerFactory()

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