edu.iu.dsc.tws.data.api.assigner

Class OrderedInputSplitAssigner<T>

java.lang.Object

edu.iu.dsc.tws.data.api.assigner.OrderedInputSplitAssigner<T>

All Implemented Interfaces:

InputSplitAssigner<T>, java.io.Serializable

public class OrderedInputSplitAssigner<T>
extends java.lang.Object
implements InputSplitAssigner<T>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
OrderedInputSplitAssigner(InputSplit<T>[] partitions, int nTasks)

Method Summary

Modifier and Type	Method and Description
InputSplit<T>	getNextInputSplit(java.lang.String host, int taskId) Returns the next input split that shall be consumed.

Methods inherited from class java.lang.Object

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

Constructor Detail

OrderedInputSplitAssigner

public OrderedInputSplitAssigner(InputSplit<T>[] partitions,
                                 int nTasks)

Method Detail

getNextInputSplit

public InputSplit<T> getNextInputSplit(java.lang.String host,
                                       int taskId)

Description copied from interface: InputSplitAssigner

Returns the next input split that shall be consumed. The consumer's host is passed as a parameter to allow localized assignments.

Specified by:

getNextInputSplit in interface InputSplitAssigner<T>

Parameters:

host - The host address of split requesting task.

taskId - The id of the split requesting task.

Returns:

the next input split to be consumed, or null if no more splits remain.