org.apache.giraph.mapping

Class DefaultLongByteOps

java.lang.Object

org.apache.giraph.mapping.AbstractLongByteOps

org.apache.giraph.mapping.DefaultLongByteOps

All Implemented Interfaces:

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

public class DefaultLongByteOps
extends AbstractLongByteOps

MappingStoreOps implementation which reads partition information from map

Field Summary

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

mappingStore

Constructor Summary

Constructors

Constructor and Description
DefaultLongByteOps() 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

DefaultLongByteOps

public DefaultLongByteOps()

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