org.apache.giraph.master.input

Class BasicInputSplitsMasterOrganizer

java.lang.Object

org.apache.giraph.master.input.BasicInputSplitsMasterOrganizer

All Implemented Interfaces:

InputSplitsMasterOrganizer

public class BasicInputSplitsMasterOrganizer
extends Object
implements InputSplitsMasterOrganizer

Input splits organizer for vertex and edge input splits on master, which doesn't use locality information

Constructor Summary

Constructors

Constructor and Description
BasicInputSplitsMasterOrganizer(List<byte[]> serializedSplits) 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

BasicInputSplitsMasterOrganizer

public BasicInputSplitsMasterOrganizer(List<byte[]> serializedSplits)

Constructor

Parameters:

serializedSplits - Splits

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