int computeNumSlotsPerReduce ( long slotSizePerReduce ) { if ( ( slotSizePerReduce == DISABLED_MEMORY_LIMIT ) || ( getMemoryForReduceTask ( ) == DISABLED_MEMORY_LIMIT ) ) { return 1 ; } return ( int ) ( Math . ceil ( ( float ) getMemoryForReduceTask ( ) / ( float ) slotSizePerReduce ) ) ; }
Compute the number of slots required to run a single reduce task - attempt of this job .