@Internal public class DefaultInputSplitAssigner extends Object implements InputSplitAssigner
InputSplitAssigner
interface. The default input
split assigner simply returns all input splits of an input vertex in an undefined order.Constructor and Description |
---|
DefaultInputSplitAssigner(Collection<? extends InputSplit> splits) |
DefaultInputSplitAssigner(InputSplit[] splits) |
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.
|
public DefaultInputSplitAssigner(InputSplit[] splits)
public DefaultInputSplitAssigner(Collection<? extends InputSplit> splits)
public InputSplit getNextInputSplit(String host, int taskId)
InputSplitAssigner
getNextInputSplit
in interface InputSplitAssigner
host
- The host address of split requesting task.taskId
- The id of the split requesting task.null
if no more splits remain.public void returnInputSplit(List<InputSplit> splits, int taskId)
InputSplitAssigner
returnInputSplit
in interface InputSplitAssigner
splits
- The list of input splits to be returned.taskId
- The id of the task that failed to process the input splits.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.