V
- public interface EvaluatorToPartitionStrategy<V extends org.apache.hadoop.mapred.InputSplit>
DataLoadingService
that uses the
Hadoop InputFormat
to partition the data and
request resources accordinglyModifier and Type | Method and Description |
---|---|
NumberedSplit<V> |
getInputSplit(NodeDescriptor nodeDescriptor,
String evalId)
Returns an input split for the given evaluator.
|
int |
getNumberOfSplits()
Returns the total number of splits computed in this strategy.
|
NumberedSplit<V> getInputSplit(NodeDescriptor nodeDescriptor, String evalId)
nodeDescriptor
- the node descriptor where the evaluator is running onevalId
- the evaluator idRuntimeException
- if no split could be allocatedint getNumberOfSplits()
Copyright © 2017 The Apache Software Foundation. All rights reserved.