InputSplitAssigner (Flink : Core 1.20.2-cp1 API)

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

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	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.