org.apache.giraph.master.input

Class LocalityAwareInputSplitsMasterOrganizer

java.lang.Object

org.apache.giraph.master.input.LocalityAwareInputSplitsMasterOrganizer

All Implemented Interfaces:

InputSplitsMasterOrganizer

public class LocalityAwareInputSplitsMasterOrganizer
extends Object
implements InputSplitsMasterOrganizer

Input splits organizer for vertex and edge input splits on master, which uses locality information

Constructor Summary

Constructors

Constructor and Description
LocalityAwareInputSplitsMasterOrganizer(List<byte[]> serializedSplits, List<org.apache.hadoop.mapreduce.InputSplit> splits, 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

LocalityAwareInputSplitsMasterOrganizer

public LocalityAwareInputSplitsMasterOrganizer(List<byte[]> serializedSplits,
                                               List<org.apache.hadoop.mapreduce.InputSplit> splits,
                                               List<WorkerInfo> workers)

Constructor

Parameters:

serializedSplits - Serialized splits

splits - 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