org.apache.giraph.edge

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

java.lang.Object

org.apache.giraph.edge.InMemoryEdgeStoreFactory<I,V,E>

Type Parameters:

I - Vertex id

V - Vertex value

E - Edge value

All Implemented Interfaces:

EdgeStoreFactory<I,V,E>

public class InMemoryEdgeStoreFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends Object
implements EdgeStoreFactory<I,V,E>

Edge store factory which produces message stores which hold all edges in memory. It creates primitive edges stores when vertex id is IntWritable or LongWritable

Field Summary

Fields

Modifier and Type	Field and Description
protected ImmutableClassesGiraphConfiguration<I,V,E>	conf Giraph configuration.
protected org.apache.hadoop.util.Progressable	progressable Progressable to report progress.
protected CentralizedServiceWorker<I,V,E>	service Service worker.

Constructor Summary

Constructors

Constructor and Description
InMemoryEdgeStoreFactory()

Method Summary

Modifier and Type	Method and Description
void	initialize(CentralizedServiceWorker<I,V,E> service, ImmutableClassesGiraphConfiguration<I,V,E> conf, org.apache.hadoop.util.Progressable progressable) Implementation class should use this method of initialization of any required internal state.
EdgeStore<I,V,E>	newStore() Creates new edge store.

Methods inherited from class java.lang.Object

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

Field Detail

service

protected CentralizedServiceWorker<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> service

Service worker.

conf

protected ImmutableClassesGiraphConfiguration<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> conf

Giraph configuration.

progressable

protected org.apache.hadoop.util.Progressable progressable

Progressable to report progress.

Constructor Detail

InMemoryEdgeStoreFactory

public InMemoryEdgeStoreFactory()

Method Detail

newStore

public EdgeStore<I,V,E> newStore()

Description copied from interface: EdgeStoreFactory

Creates new edge store.

Specified by:

newStore in interface EdgeStoreFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Returns:

edge store

initialize

public void initialize(CentralizedServiceWorker<I,V,E> service,
                       ImmutableClassesGiraphConfiguration<I,V,E> conf,
                       org.apache.hadoop.util.Progressable progressable)

Description copied from interface: EdgeStoreFactory

Implementation class should use this method of initialization of any required internal state.

Specified by:

initialize in interface EdgeStoreFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Parameters:

service - Service to get partition mappings

conf - Configuration

progressable - Progressable