org.apache.giraph.partition

Interface GraphPartitionerFactoryInterface<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Type Parameters:

I - Vertex index value

V - Vertex value

E - Edge value

All Superinterfaces:

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

All Known Implementing Classes:

GraphPartitionerFactory, HashPartitionerFactory, HashRangePartitionerFactory, LongMappingStorePartitionerFactory, SimpleIntRangePartitionerFactory, SimpleLongRangePartitionerFactory

public interface GraphPartitionerFactoryInterface<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends ImmutableClassesGiraphConfigurable<I,V,E>

Defines the partitioning framework for this application.

Method Summary

Modifier and Type	Method and Description
MasterGraphPartitioner<I,V,E>	createMasterGraphPartitioner() Create the MasterGraphPartitioner used by the master.
WorkerGraphPartitioner<I,V,E>	createWorkerGraphPartitioner() Create the WorkerGraphPartitioner used by the worker.
void	initialize(LocalData<I,V,E,? extends org.apache.hadoop.io.Writable> localData) Use some local data present in the worker

Methods inherited from interface org.apache.giraph.conf.ImmutableClassesGiraphConfigurable

getConf

Methods inherited from interface org.apache.giraph.conf.GiraphConfigurationSettable

setConf

Method Detail

initialize

void initialize(LocalData<I,V,E,? extends org.apache.hadoop.io.Writable> localData)

Use some local data present in the worker

Parameters:

localData - localData present in the worker

createMasterGraphPartitioner

MasterGraphPartitioner<I,V,E> createMasterGraphPartitioner()

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

Returns:

Instantiated master graph partitioner

createWorkerGraphPartitioner

WorkerGraphPartitioner<I,V,E> createWorkerGraphPartitioner()

Create the WorkerGraphPartitioner used by the worker. Instantiated once by every worker and reused.

Returns:

Instantiated worker graph partitioner