org.apache.giraph.mapping

Class LongByteMappingStore

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

org.apache.giraph.mapping.LongByteMappingStore

All Implemented Interfaces:

GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>, MappingStore<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.ByteWritable>

@ThreadSafe
public class LongByteMappingStore
extends DefaultImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
implements MappingStore<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.ByteWritable>

An implementation of MappingStore<LongWritable, ByteWritable> Methods implemented here are thread safe by default because it is guaranteed that each entry is written to only once. It can represent up to a maximum of 254 workers any byte passed is treated as unsigned

Constructor Summary

Constructors

Constructor and Description
LongByteMappingStore()

Method Summary

Modifier and Type	Method and Description
void	addEntry(org.apache.hadoop.io.LongWritable vertexId, org.apache.hadoop.io.ByteWritable target) Add an entry to the mapping store
byte	getByteTarget(org.apache.hadoop.io.LongWritable vertexId) Auxiliary method to be used by getTarget
long	getStats() Get stats about the MappingStore
org.apache.hadoop.io.ByteWritable	getTarget(org.apache.hadoop.io.LongWritable vertexId, org.apache.hadoop.io.ByteWritable target) Get target for given vertexId
void	initialize() Must be called before anything else can be done on this instance
void	postFilling() Operations to perform after adding entries to the mapping store

Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

getConf, setConf

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.conf.ImmutableClassesGiraphConfigurable

getConf

Methods inherited from interface org.apache.giraph.conf.GiraphConfigurationSettable

setConf

Constructor Detail

LongByteMappingStore

public LongByteMappingStore()

Method Detail

initialize

public void initialize()

Description copied from interface: MappingStore

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

Specified by:

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

getByteTarget

public byte getByteTarget(org.apache.hadoop.io.LongWritable vertexId)

Auxiliary method to be used by getTarget

Parameters:

vertexId - vertexId

Returns:

return byte value of target

addEntry

public void addEntry(org.apache.hadoop.io.LongWritable vertexId,
                     org.apache.hadoop.io.ByteWritable target)

Description copied from interface: MappingStore

Add an entry to the mapping store

Specified by:

addEntry in interface MappingStore<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.ByteWritable>

Parameters:

vertexId - vertexId

target - target

getTarget

public org.apache.hadoop.io.ByteWritable getTarget(org.apache.hadoop.io.LongWritable vertexId,
                                                   org.apache.hadoop.io.ByteWritable target)

Description copied from interface: MappingStore

Get target for given vertexId

Specified by:

getTarget in interface MappingStore<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.ByteWritable>

Parameters:

vertexId - vertexId

target - instance to use for storing target information

Returns:

target instance

postFilling

public void postFilling()

Description copied from interface: MappingStore

Operations to perform after adding entries to the mapping store

Specified by:

postFilling in interface MappingStore<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.ByteWritable>

getStats

public long getStats()

Description copied from interface: MappingStore

Get stats about the MappingStore

Specified by:

getStats in interface MappingStore<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.ByteWritable>

Returns:

numEntries