org.apache.giraph.master.input

Class MappingInputSplitsMasterOrganizer

java.lang.Object

org.apache.giraph.master.input.MappingInputSplitsMasterOrganizer

All Implemented Interfaces:

InputSplitsMasterOrganizer

public class MappingInputSplitsMasterOrganizer
extends Object
implements InputSplitsMasterOrganizer

Organizer for mapping splits on master. Mapping splits need all to be given to all workers, unlike vertex and edge splits which are read by exactly one worker each

Constructor Summary

Constructors

Constructor and Description
MappingInputSplitsMasterOrganizer(List<byte[]> serializedSplits, List<WorkerInfo> workers) Constructor

Method Summary

Modifier and Type	Method and Description
byte[]	getSerializedSplitFor(int workerTaskId)

Methods inherited from class java.lang.Object

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

Constructor Detail

MappingInputSplitsMasterOrganizer

public MappingInputSplitsMasterOrganizer(List<byte[]> serializedSplits,
                                         List<WorkerInfo> workers)

Constructor

Parameters:

serializedSplits - Splits

workers - List of workers

Method Detail

getSerializedSplitFor

public byte[] getSerializedSplitFor(int workerTaskId)

Specified by:

getSerializedSplitFor in interface InputSplitsMasterOrganizer

Parameters:

workerTaskId - Id of worker requesting split

Returns:

Get next split for the worker, or null if all splits were taken already