Class ResultMergeRemoteSpark
- java.lang.Object
- 
- org.apache.sysds.runtime.controlprogram.parfor.ResultMerge<MatrixObject>
- 
- org.apache.sysds.runtime.controlprogram.parfor.ResultMergeMatrix
- 
- org.apache.sysds.runtime.controlprogram.parfor.ResultMergeRemoteSpark
 
 
 
- 
- All Implemented Interfaces:
- Serializable
 
 public class ResultMergeRemoteSpark extends ResultMergeMatrix - See Also:
- Serialized Form
 
- 
- 
Constructor SummaryConstructors Constructor Description ResultMergeRemoteSpark(MatrixObject out, MatrixObject[] in, String outputFilename, boolean accum, ExecutionContext ec, int numMappers, int numReducers)
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description MatrixObjectexecuteParallelMerge(int par)Merge all given input matrices in parallel into the given output matrix.MatrixObjectexecuteSerialMerge()Merge all given input matrices sequentially into the given output matrix.
 
- 
- 
- 
Constructor Detail- 
ResultMergeRemoteSparkpublic ResultMergeRemoteSpark(MatrixObject out, MatrixObject[] in, String outputFilename, boolean accum, ExecutionContext ec, int numMappers, int numReducers) 
 
- 
 - 
Method Detail- 
executeSerialMergepublic MatrixObject executeSerialMerge() Description copied from class:ResultMergeMerge 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:
- executeSerialMergein class- ResultMerge<MatrixObject>
- Returns:
- output (merged) matrix
 
 - 
executeParallelMergepublic MatrixObject executeParallelMerge(int par) Description copied from class:ResultMergeMerge 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:
- executeParallelMergein class- ResultMerge<MatrixObject>
- Parameters:
- par- degree of parallelism
- Returns:
- output (merged) matrix
 
 
- 
 
-