Data Science, Machine Learning.
a_mat_para = parallelize_matrix(a_mat, rows_per_chunk=100) b_mat_dist = broadcast_matrix(a_mat) a_mat_para.flatMap( lambda submatrix: find_matches_in_submatrix(csr_matrix(submatrix[1], shape=submatrix[2]), b_mat_dist, submatrix[0])) def find_matches_in_submatrix(sources, targets,