org.apache.sysml.runtime.matrix

Class MMCJMR



  • public class MMCJMR
    extends Object
    • Method Detail

      • determineNumReducers

        protected static int determineNumReducers(long[] rlen,
                                                  long[] clen,
                                                  int defaultNumRed,
                                                  long numRedGroups)
        Determine number of reducers based on configured number of reducers, number of results groups and input data divided by blocksize (as heuristic for useful degree of parallelism).
        Parameters:
        rlen - array of numbers of rows
        clen - array of numbers of columns
        defaultNumRed - default number of reducers
        numRedGroups - number of reducer groups
        Returns:
        number of reducers

Copyright © 2017 The Apache Software Foundation. All rights reserved.