V
- public class EvaluatorToPartitionMapper<V extends org.apache.hadoop.mapred.InputSplit> extends Object
DataLoadingService
that uses the Hadoop InputFormat
to
partition the data and request resources
accordingly
This is an online version which satisfies
requests in a greedy way.Constructor and Description |
---|
EvaluatorToPartitionMapper(V[] splits)
Initializes the locations of splits mapping
|
Modifier and Type | Method and Description |
---|---|
org.apache.reef.io.data.loading.impl.NumberedSplit<V> |
getInputSplit(String hostName,
String evaluatorId)
Get an input split to be assigned to this
evaluator
Allocates one if its not already allocated
|
public EvaluatorToPartitionMapper(V[] splits)
splits
- public org.apache.reef.io.data.loading.impl.NumberedSplit<V> getInputSplit(String hostName, String evaluatorId)
evaluatorId
- Copyright © 2015 The Apache Software Foundation. All rights reserved.