org.apache.giraph.factories

Interface ComputationFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable>

Type Parameters:

I - Vertex ID

V - Vertex Value

E - Edge Value

M1 - Incoming Message Value

M2 - Outgoing Message Value

All Known Implementing Classes:

DefaultComputationFactory, JythonComputationFactory

public interface ComputationFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable>

Factory for creating Computations

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,M1,M2>	createComputation(ImmutableClassesGiraphConfiguration<I,V,E> conf) Get Computation object
void	initialize(ImmutableClassesGiraphConfiguration<I,V,E> conf) One time initialization before compute calls.

Method Detail

initialize

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

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

Parameters:

conf - Configuration

createComputation

Computation<I,V,E,M1,M2> createComputation(ImmutableClassesGiraphConfiguration<I,V,E> conf)

Get Computation object

Parameters:

conf - Configuration

Returns:

Computation

checkConfiguration

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

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

Parameters:

conf - Configuration to check.

computationName

String computationName(GiraphConfiguration conf)

Get name of this particular computation

Parameters:

conf - Configuration

Returns:

String name of computation