org.apache.giraph.comm.messages

Interface PartitionSplitInfo<I extends org.apache.hadoop.io.WritableComparable>

Type Parameters:

I - Vertex id type.

All Known Subinterfaces:

CentralizedServiceWorker<I,V,E>

All Known Implementing Classes:

BspServiceWorker

public interface PartitionSplitInfo<I extends org.apache.hadoop.io.WritableComparable>

Interface providing partition split information.

Method Summary

Modifier and Type	Method and Description
Partition	getNextPartition() PartitionStore.getNextPartition()
int	getPartitionId(I vertexId) Get the partition id that a vertex id would belong to.
Iterable<Integer>	getPartitionIds() Get the ids of all the stored partitions (on current worker) as Iterable
long	getPartitionVertexCount(Integer partitionId) Return the number of vertices in a partition.
void	putPartition(Partition partition) PartitionStore.putPartition(Partition)
void	startIteration() PartitionStore.startIteration()

Method Detail

getPartitionId

int getPartitionId(I vertexId)

Get the partition id that a vertex id would belong to.

Parameters:

vertexId - Vertex id

Returns:

Partition id

getPartitionIds

Iterable<Integer> getPartitionIds()

Get the ids of all the stored partitions (on current worker) as Iterable

Returns:

The partition ids

getPartitionVertexCount

long getPartitionVertexCount(Integer partitionId)

Return the number of vertices in a partition.

Parameters:

partitionId - Partition id

Returns:

The number of vertices in the specified partition

startIteration

void startIteration()

PartitionStore.startIteration()

getNextPartition

Partition getNextPartition()

PartitionStore.getNextPartition()

Returns:

The next partition to process

putPartition

void putPartition(Partition partition)

PartitionStore.putPartition(Partition)

Parameters:

partition - Partition