public class MappingInputSplitsMasterOrganizer extends Object implements InputSplitsMasterOrganizer
Constructor and Description |
---|
MappingInputSplitsMasterOrganizer(List<byte[]> serializedSplits,
List<WorkerInfo> workers)
Constructor
|
Modifier and Type | Method and Description |
---|---|
byte[] |
getSerializedSplitFor(int workerTaskId) |
public MappingInputSplitsMasterOrganizer(List<byte[]> serializedSplits, List<WorkerInfo> workers)
serializedSplits
- Splitsworkers
- List of workerspublic byte[] getSerializedSplitFor(int workerTaskId)
getSerializedSplitFor
in interface InputSplitsMasterOrganizer
workerTaskId
- Id of worker requesting splitCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.