org.apache.giraph.mapping

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

Type Parameters:

I - vertexId type

B - mappingTarget type

All Superinterfaces:

GiraphConfigurationSettable<I,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>, ImmutableClassesGiraphConfigurable<I,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

All Known Implementing Classes:

LongByteMappingStore

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

MappingStore used to store the vertexId - target map supplied by user Methods implemented in this class need to be thread safe

Method Summary

Modifier and Type	Method and Description
void	addEntry(I vertexId, B target) Add an entry to the mapping store
long	getStats() Get stats about the MappingStore
B	getTarget(I vertexId, B 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 interface org.apache.giraph.conf.ImmutableClassesGiraphConfigurable

getConf

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

setConf

Method Detail

initialize

void initialize()

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

addEntry

void addEntry(I vertexId,
              B target)

Add an entry to the mapping store

Parameters:

vertexId - vertexId

target - target

getTarget

B getTarget(I vertexId,
            B target)

Get target for given vertexId

Parameters:

vertexId - vertexId

target - instance to use for storing target information

Returns:

target instance

postFilling

void postFilling()

Operations to perform after adding entries to the mapping store

getStats

long getStats()

Get stats about the MappingStore

Returns:

numEntries