org.apache.giraph.worker

Class LocalData<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,B extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

org.apache.giraph.worker.LocalData<I,V,E,B>

Type Parameters:

I - vertexId type

V - vertex value type

E - edge value type

B - mappingTarget type

All Implemented Interfaces:

GiraphConfigurationSettable<I,V,E>, ImmutableClassesGiraphConfigurable<I,V,E>

public class LocalData<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,B extends org.apache.hadoop.io.Writable>
extends DefaultImmutableClassesGiraphConfigurable<I,V,E>

Stores LocalData for each worker

Constructor Summary

Constructors

Constructor and Description
LocalData(ImmutableClassesGiraphConfiguration<I,V,E> conf) Constructor Set configuration, create & initialize mapping store

Method Summary

Modifier and Type	Method and Description
MappingStore<I,B>	getMappingStore()
MappingStoreOps<I,B>	getMappingStoreOps()
void	printStats() Prints Stats of individual data it stores
void	removeMappingStoreIfPossible() Remove mapping store from localData if mapping data is already embedded into vertexIds

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

Constructor Detail

LocalData

public LocalData(ImmutableClassesGiraphConfiguration<I,V,E> conf)

Constructor Set configuration, create & initialize mapping store

Parameters:

conf - giraph configuration

Method Detail

getMappingStore

public MappingStore<I,B> getMappingStore()

getMappingStoreOps

public MappingStoreOps<I,B> getMappingStoreOps()

removeMappingStoreIfPossible

public void removeMappingStoreIfPossible()

Remove mapping store from localData if mapping data is already embedded into vertexIds

printStats

public void printStats()

Prints Stats of individual data it stores