org.apache.giraph.worker

Class EdgeInputSplitsCallableFactory<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.worker.EdgeInputSplitsCallableFactory<I,V,E>

Type Parameters:

I - Vertex id

V - Vertex value

E - Edge value

All Implemented Interfaces:

CallableFactory<VertexEdgeCount>

public class EdgeInputSplitsCallableFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends Object
implements CallableFactory<VertexEdgeCount>

Factory for EdgeInputSplitsCallables.

Constructor Summary

Constructors

Constructor and Description
EdgeInputSplitsCallableFactory(EdgeInputFormat<I,E> edgeInputFormat, org.apache.hadoop.mapreduce.Mapper.Context context, ImmutableClassesGiraphConfiguration<I,V,E> configuration, BspServiceWorker<I,V,E> bspServiceWorker, WorkerInputSplitsHandler splitsHandler) Constructor.

Method Summary

Modifier and Type	Method and Description
InputSplitsCallable<I,V,E>	newCallable(int threadId) Create new callable

Methods inherited from class java.lang.Object

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

Constructor Detail

EdgeInputSplitsCallableFactory

public EdgeInputSplitsCallableFactory(EdgeInputFormat<I,E> edgeInputFormat,
                                      org.apache.hadoop.mapreduce.Mapper.Context context,
                                      ImmutableClassesGiraphConfiguration<I,V,E> configuration,
                                      BspServiceWorker<I,V,E> bspServiceWorker,
                                      WorkerInputSplitsHandler splitsHandler)

Constructor.

Parameters:

edgeInputFormat - Edge input format

context - Mapper context

configuration - Configuration

bspServiceWorker - Calling BspServiceWorker

splitsHandler - Handler for input splits

Method Detail

newCallable

public InputSplitsCallable<I,V,E> newCallable(int threadId)

Description copied from interface: CallableFactory

Create new callable

Specified by:

newCallable in interface CallableFactory<VertexEdgeCount>

Parameters:

threadId - Id of the callable

Returns:

Callable