@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 the order they were originally computed.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.
|
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.Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.