org.apache.giraph.worker

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

java.lang.Object

org.apache.giraph.worker.MappingInputSplitsCallableFactory<I,V,E,B>

Type Parameters:

I - vertexId type

V - vertexValue type

E - edgeValue type

B - mappingTarget type

All Implemented Interfaces:

CallableFactory<VertexEdgeCount>

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

Factory for MappingInputSplitsCallables.

Constructor Summary

Constructors

Constructor and Description
MappingInputSplitsCallableFactory(MappingInputFormat<I,V,E,B> mappingInputFormat, 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

MappingInputSplitsCallableFactory

public MappingInputSplitsCallableFactory(MappingInputFormat<I,V,E,B> mappingInputFormat,
                                         org.apache.hadoop.mapreduce.Mapper.Context context,
                                         ImmutableClassesGiraphConfiguration<I,V,E> configuration,
                                         BspServiceWorker<I,V,E> bspServiceWorker,
                                         WorkerInputSplitsHandler splitsHandler)

Constructor.

Parameters:

mappingInputFormat - Mapping input format

context - Mapper context

configuration - Configuration

bspServiceWorker - Calling BspServiceWorker

splitsHandler - Splits handler

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