org.apache.giraph.mapping

Class AbstractLongByteOps

java.lang.Object

org.apache.giraph.mapping.AbstractLongByteOps

All Implemented Interfaces:

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

Direct Known Subclasses:

DefaultEmbeddedLongByteOps, DefaultLongByteOps

public abstract class AbstractLongByteOps
extends Object
implements MappingStoreOps<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.ByteWritable>

Implementation of basic methods in MappingStoreOps

Field Summary

Fields

Modifier and Type	Field and Description
protected LongByteMappingStore	mappingStore Mapping store instance to operate on

Constructor Summary

Constructors

Constructor and Description
AbstractLongByteOps()

Method Summary

Modifier and Type	Method and Description
protected int	computePartition(org.apache.hadoop.io.LongWritable id, int partitionCount, int workerCount, byte target) Compute partition given id, partitionCount, workerCount & target
void	initialize(MappingStore<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.ByteWritable> mappingStore) Must be called before anything else can be done on this instance

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.giraph.mapping.MappingStoreOps

embedTargetInfo, getPartition, hasEmbedding, removeTargetInfo

Field Detail

mappingStore

protected LongByteMappingStore mappingStore

Mapping store instance to operate on

Constructor Detail

AbstractLongByteOps

public AbstractLongByteOps()

Method Detail

initialize

public void initialize(MappingStore<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.ByteWritable> mappingStore)

Description copied from interface: MappingStoreOps

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

Specified by:

initialize in interface MappingStoreOps<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.ByteWritable>

Parameters:

mappingStore - mapping store instance to operate on

computePartition

protected int computePartition(org.apache.hadoop.io.LongWritable id,
                               int partitionCount,
                               int workerCount,
                               byte target)

Compute partition given id, partitionCount, workerCount & target

Parameters:

id - vertex id

partitionCount - number of partitions

workerCount - number of workers

target - target worker

Returns:

partition number