org.apache.giraph.mapping

Class DefaultEmbeddedLongByteOps

java.lang.Object

org.apache.giraph.mapping.AbstractLongByteOps

org.apache.giraph.mapping.DefaultEmbeddedLongByteOps

All Implemented Interfaces:

MappingStoreOps<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.ByteWritable>

public class DefaultEmbeddedLongByteOps
extends AbstractLongByteOps

MappingStoreOps implementation used to embed target information into vertex id. Stores information in the higher order bits of the long id

Field Summary

Fields inherited from class org.apache.giraph.mapping.AbstractLongByteOps

mappingStore

Constructor Summary

Constructors

Constructor and Description
DefaultEmbeddedLongByteOps() Default constructor (do not use)

Method Summary

Modifier and Type	Method and Description
void	embedTargetInfo(org.apache.hadoop.io.LongWritable id) Embed target information into vertexId
int	getPartition(org.apache.hadoop.io.LongWritable id, int partitionCount, int workerCount) Get partition id for a vertex id
boolean	hasEmbedding() True if MappingStoreOps is based on embedding info
void	removeTargetInfo(org.apache.hadoop.io.LongWritable id) Remove target information from vertexId

Methods inherited from class org.apache.giraph.mapping.AbstractLongByteOps

computePartition, initialize

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultEmbeddedLongByteOps

public DefaultEmbeddedLongByteOps()

Default constructor (do not use)

Method Detail

hasEmbedding

public boolean hasEmbedding()

Description copied from interface: MappingStoreOps

True if MappingStoreOps is based on embedding info

Returns:

true if worker info is embedded into vertex ids

embedTargetInfo

public void embedTargetInfo(org.apache.hadoop.io.LongWritable id)

Description copied from interface: MappingStoreOps

Embed target information into vertexId

Parameters:

id - vertexId

removeTargetInfo

public void removeTargetInfo(org.apache.hadoop.io.LongWritable id)

Description copied from interface: MappingStoreOps

Remove target information from vertexId

Parameters:

id - vertexId

getPartition

public int getPartition(org.apache.hadoop.io.LongWritable id,
                        int partitionCount,
                        int workerCount)

Description copied from interface: MappingStoreOps

Get partition id for a vertex id

Parameters:

id - vertexId

partitionCount - partitionCount

workerCount - workerCount

Returns:

partition of vertex id