Class ResultMergeRemoteSpark

    • Method Detail

      • executeSerialMerge

        public MatrixObject executeSerialMerge()
        Description copied from class: ResultMerge
        Merge all given input matrices sequentially into the given output matrix. The required space in-memory is the size of the output matrix plus the size of one input matrix at a time.
        Specified by:
        executeSerialMerge in class ResultMerge<MatrixObject>
        Returns:
        output (merged) matrix
      • executeParallelMerge

        public MatrixObject executeParallelMerge​(int par)
        Description copied from class: ResultMerge
        Merge all given input matrices in parallel into the given output matrix. The required space in-memory is the size of the output matrix plus the size of all input matrices.
        Specified by:
        executeParallelMerge in class ResultMerge<MatrixObject>
        Parameters:
        par - degree of parallelism
        Returns:
        output (merged) matrix