edu.iu.dsc.tws.data.fs.io

Interface InputSplitAssigner<T>

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

LocatableInputSplitAssigner, OrderedInputSplitAssigner

public interface InputSplitAssigner<T>
extends java.io.Serializable

An input split assigner distributes the InputSplits among the instances on which a data source exists.

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.

Method Detail

getNextInputSplit

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

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

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.