public static class ExecutionJobVertex.PredeterminedInputSplitAssigner extends Object implements InputSplitAssigner
Constructor and Description |
---|
PredeterminedInputSplitAssigner(List<LocatableInputSplit>[] inputSplitsPerSubtask) |
Modifier and Type | Method and Description |
---|---|
InputSplit |
getNextInputSplit(String host,
int taskId)
Returns the next input split that shall be consumed.
|
public PredeterminedInputSplitAssigner(List<LocatableInputSplit>[] inputSplitsPerSubtask)
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–2017 The Apache Software Foundation. All rights reserved.