@PublicEvolving public interface InputSplitAssigner
InputSplit
s among the instances on which a data
source exists.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.
|
InputSplit getNextInputSplit(String host, int taskId)
host
- The host address of split requesting task.taskId
- The id of the split requesting task.null
if no more splits remain.void returnInputSplit(List<InputSplit> splits, int taskId)
splits
- The list of input splits to be returned.taskId
- The id of the task that failed to process the input splits.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.