org.apache.giraph.factories

Class DefaultComputationFactory<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.factories.DefaultComputationFactory<I,V,E>

Type Parameters:

I - Vertex ID

V - Vertex Value

E - Edge Value

All Implemented Interfaces:

ComputationFactory<I,V,E,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

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

Default computation factory that simply creates java computation object

Constructor Summary

Constructors

Constructor and Description
DefaultComputationFactory()

Method Summary

Modifier and Type	Method and Description
void	checkConfiguration(ImmutableClassesGiraphConfiguration<I,V,E> conf) Check that the Configuration passed in is setup correctly to run a job.
String	computationName(GiraphConfiguration conf) Get name of this particular computation
Computation<I,V,E,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>	createComputation(ImmutableClassesGiraphConfiguration<I,V,E> conf) Get Computation object
void	initialize(ImmutableClassesGiraphConfiguration<I,V,E> conf) One time initialization before compute calls.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultComputationFactory

public DefaultComputationFactory()

Method Detail

initialize

public void initialize(ImmutableClassesGiraphConfiguration<I,V,E> conf)

Description copied from interface: ComputationFactory

One time initialization before compute calls. Guaranteed to be called from only one thread before computation begins.

Specified by:

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

Parameters:

conf - Configuration

createComputation

public Computation<I,V,E,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> createComputation(ImmutableClassesGiraphConfiguration<I,V,E> conf)

Description copied from interface: ComputationFactory

Get Computation object

Specified by:

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

Parameters:

conf - Configuration

Returns:

Computation

checkConfiguration

public void checkConfiguration(ImmutableClassesGiraphConfiguration<I,V,E> conf)

Description copied from interface: ComputationFactory

Check that the Configuration passed in is setup correctly to run a job.

Specified by:

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

Parameters:

conf - Configuration to check.

computationName

public String computationName(GiraphConfiguration conf)

Description copied from interface: ComputationFactory

Get name of this particular computation

Specified by:

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

Parameters:

conf - Configuration

Returns:

String name of computation