@PublicEvolving public interface InputSplitAssigner
InputSplits among the instances on which a data source exists.
|Modifier and Type||Method and Description|
Returns the next input split that shall be consumed.
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.
nullif 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–2020 The Apache Software Foundation. All rights reserved.