org.apache.giraph.partition

Class SimpleIntRangePartitionerFactory<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<org.apache.hadoop.io.IntWritable,V,E>

org.apache.giraph.partition.SimpleIntRangePartitionerFactory<V,E>

Type Parameters:

V - Vertex value type

E - Edge value type

All Implemented Interfaces:

GiraphConfigurationSettable<org.apache.hadoop.io.IntWritable,V,E>, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.IntWritable,V,E>, GraphPartitionerFactoryInterface<org.apache.hadoop.io.IntWritable,V,E>

public class SimpleIntRangePartitionerFactory<V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends GraphPartitionerFactory<org.apache.hadoop.io.IntWritable,V,E>

Factory for simple range-based partitioners based on integer vertex ids. Workers are assigned equal-sized ranges of partitions, and partitions are assigned equal-sized ranges of vertices.

Constructor Summary

Constructors

Constructor and Description
SimpleIntRangePartitionerFactory()

Method Summary

Modifier and Type	Method and Description
protected int	getPartition(org.apache.hadoop.io.IntWritable id, int partitionCount) Calculates in which partition current vertex belongs to, from interval [0, partitionCount).
int	getPartition(org.apache.hadoop.io.IntWritable 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.
void	setConf(ImmutableClassesGiraphConfiguration conf) Set the configuration to be used by this object.

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

createMasterGraphPartitioner, createWorkerGraphPartitioner, getPartitionInRange, getPartitionInRange, initialize

Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

getConf

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

Constructor Detail

SimpleIntRangePartitionerFactory

public SimpleIntRangePartitionerFactory()

Method Detail

getPartition

public int getPartition(org.apache.hadoop.io.IntWritable 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<org.apache.hadoop.io.IntWritable,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

getPartition

protected int getPartition(org.apache.hadoop.io.IntWritable id,
                           int partitionCount)

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

Parameters:

id - Vertex id

partitionCount - Number of partitions

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<org.apache.hadoop.io.IntWritable,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

setConf

public void setConf(ImmutableClassesGiraphConfiguration conf)

Description copied from interface: GiraphConfigurationSettable

Set the configuration to be used by this object.

Specified by:

setConf in interface GiraphConfigurationSettable<org.apache.hadoop.io.IntWritable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Overrides:

setConf in class DefaultImmutableClassesGiraphConfigurable<org.apache.hadoop.io.IntWritable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Parameters:

conf - Set configuration