org.apache.giraph.integration

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

java.lang.Object

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

org.apache.giraph.integration.SuperstepHashPartitionerFactory<I,V,E,M>

Type Parameters:

I - Vertex id

V - Vertex value

E - Edge value

M - Message data

All Implemented Interfaces:

ImmutableClassesGiraphConfigurable, GraphPartitionerFactory<I,V,E,M>

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

Example graph partitioner that builds on HashMasterPartitioner to send the partitions to the worker that matches the superstep. It is for testing only and should never be used in practice.

Constructor Summary

Constructors

Constructor and Description
SuperstepHashPartitionerFactory()

Method Summary

Methods

Modifier and Type	Method and Description
MasterGraphPartitioner<I,V,E,M>	createMasterGraphPartitioner() Create the MasterGraphPartitioner used by the master.

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

createWorkerGraphPartitioner, getConf, setConf

Methods inherited from class java.lang.Object

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

Constructor Detail

SuperstepHashPartitionerFactory

public SuperstepHashPartitionerFactory()

Method Detail

createMasterGraphPartitioner

public MasterGraphPartitioner<I,V,E,M> createMasterGraphPartitioner()

Description copied from interface: GraphPartitionerFactory

Create the MasterGraphPartitioner used by the master. Instantiated once by the master and reused.

Specified by:

createMasterGraphPartitioner in interface GraphPartitionerFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable>

Overrides:

createMasterGraphPartitioner in class HashPartitionerFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable>

Returns:

Instantiated master graph partitioner