org.apache.giraph.worker

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

Type Parameters:

I - Vertex id

V - Vertex value

E - Edge value

All Implemented Interfaces:

CallableFactory<VertexEdgeCount>

public class VertexInputSplitsCallableFactory<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 VertexInputSplitsCallables.

Constructor Summary

Constructors

Constructor and Description
VertexInputSplitsCallableFactory(VertexInputFormat<I,V,E> vertexInputFormat, 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

VertexInputSplitsCallableFactory

public VertexInputSplitsCallableFactory(VertexInputFormat<I,V,E> vertexInputFormat,
                                        org.apache.hadoop.mapreduce.Mapper.Context context,
                                        ImmutableClassesGiraphConfiguration<I,V,E> configuration,
                                        BspServiceWorker<I,V,E> bspServiceWorker,
                                        WorkerInputSplitsHandler splitsHandler)

Constructor.

Parameters:

vertexInputFormat - Vertex 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