org.apache.giraph.mapping

Interface MappingStoreOps<I extends org.apache.hadoop.io.WritableComparable,B extends org.apache.hadoop.io.Writable>

Type Parameters:

I - vertex id type

B - mapping target type

All Known Implementing Classes:

AbstractLongByteOps, DefaultEmbeddedLongByteOps, DefaultLongByteOps

public interface MappingStoreOps<I extends org.apache.hadoop.io.WritableComparable,B extends org.apache.hadoop.io.Writable>

Interface of operations that can be done on mapping store once it is fully loaded

Method Summary

Modifier and Type	Method and Description
void	embedTargetInfo(I id) Embed target information into vertexId
int	getPartition(I id, int partitionCount, int workerCount) Get partition id for a vertex id
boolean	hasEmbedding() True if MappingStoreOps is based on embedding info
void	initialize(MappingStore<I,B> mappingStore) Must be called before anything else can be done on this instance
void	removeTargetInfo(I id) Remove target information from vertexId

Method Detail

initialize

void initialize(MappingStore<I,B> mappingStore)

Must be called before anything else can be done on this instance

Parameters:

mappingStore - mapping store instance to operate on

hasEmbedding

boolean hasEmbedding()

True if MappingStoreOps is based on embedding info

Returns:

true if worker info is embedded into vertex ids

embedTargetInfo

void embedTargetInfo(I id)

Embed target information into vertexId

Parameters:

id - vertexId

removeTargetInfo

void removeTargetInfo(I id)

Remove target information from vertexId

Parameters:

id - vertexId

getPartition

int getPartition(I id,
                 int partitionCount,
                 int workerCount)

Get partition id for a vertex id

Parameters:

id - vertexId

partitionCount - partitionCount

workerCount - workerCount

Returns:

partition of vertex id