org.apache.reef.io.data.loading.impl

Class AbstractEvaluatorToPartitionStrategy

java.lang.Object

org.apache.reef.io.data.loading.impl.AbstractEvaluatorToPartitionStrategy

All Implemented Interfaces:

EvaluatorToPartitionStrategy<org.apache.hadoop.mapred.InputSplit>

Direct Known Subclasses:

MultiDataCenterEvaluatorToPartitionStrategy, SingleDataCenterEvaluatorToPartitionStrategy

public abstract class AbstractEvaluatorToPartitionStrategy
extends Object
implements EvaluatorToPartitionStrategy<org.apache.hadoop.mapred.InputSplit>

This is an abstract class useful for EvaluatorToPartitionStrategy implementations. Contains a template implementation of EvaluatorToPartitionStrategy.getInputSplit(NodeDescriptor, String) that call abstract methods implemented by subclasses. If your implementation does not need this logic, you should just implement the EvaluatorToPartitionStrategy interface and do not extend this class.

Method Summary

Methods

Modifier and Type	Method and Description
NumberedSplit<org.apache.hadoop.mapred.InputSplit>	getInputSplit(NodeDescriptor nodeDescriptor, String evaluatorId) Get an input split to be assigned to this evaluator.
int	getNumberOfSplits() Returns the total number of splits computed in this strategy.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getInputSplit

public NumberedSplit<org.apache.hadoop.mapred.InputSplit> getInputSplit(NodeDescriptor nodeDescriptor,
                                                               String evaluatorId)

Get an input split to be assigned to this evaluator.

Allocates one if its not already allocated

Specified by:

getInputSplit in interface EvaluatorToPartitionStrategy<org.apache.hadoop.mapred.InputSplit>

Parameters:

evaluatorId -

nodeDescriptor - the node descriptor where the evaluator is running on

Returns:

a numberedSplit

Throws:

RuntimeException - if couldn't find any split

getNumberOfSplits

public int getNumberOfSplits()

Description copied from interface: EvaluatorToPartitionStrategy

Returns the total number of splits computed in this strategy.

Specified by:

getNumberOfSplits in interface EvaluatorToPartitionStrategy<org.apache.hadoop.mapred.InputSplit>

Returns:

the number of splits