org.apache.flink.core.io

Interface InputSplitAssigner

All Known Implementing Classes:

DefaultInputSplitAssigner, LocatableInputSplitAssigner, ReplicatingInputSplitAssigner

@PublicEvolving
public interface InputSplitAssigner

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	getNextInputSplit(String host, int taskId) Returns the next input split that shall be consumed.
void	returnInputSplit(List<InputSplit> splits, int taskId) Return the splits to assigner if the task failed to process it.

Method Detail

getNextInputSplit

InputSplit getNextInputSplit(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.

returnInputSplit

void returnInputSplit(List<InputSplit> splits,
                      int taskId)

Return the splits to assigner if the task failed to process it.

Parameters:

splits - The list of input splits to be returned.

taskId - The id of the task that failed to process the input splits.