Class ResultMergeLocalFile
- java.lang.Object
- 
- org.apache.sysds.runtime.controlprogram.parfor.ResultMerge<MatrixObject>
- 
- org.apache.sysds.runtime.controlprogram.parfor.ResultMergeMatrix
- 
- org.apache.sysds.runtime.controlprogram.parfor.ResultMergeLocalFile
 
 
 
- 
- All Implemented Interfaces:
- Serializable
 
 public class ResultMergeLocalFile extends ResultMergeMatrix TODO potential extension: parallel merge (create individual staging files concurrently) NOTE: file merge typically used due to memory constraints - parallel merge would increase the memory consumption again.- See Also:
- Serialized Form
 
- 
- 
Field SummaryFields Modifier and Type Field Description static booleanALLOW_COPY_CELLFILES
 - 
Constructor SummaryConstructors Constructor Description ResultMergeLocalFile(MatrixObject out, MatrixObject[] in, String outputFilename, boolean accum)
 - 
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.
 
- 
- 
- 
Field Detail- 
ALLOW_COPY_CELLFILESpublic static final boolean ALLOW_COPY_CELLFILES - See Also:
- Constant Field Values
 
 
- 
 - 
Constructor Detail- 
ResultMergeLocalFilepublic ResultMergeLocalFile(MatrixObject out, MatrixObject[] in, String outputFilename, boolean accum) 
 
- 
 - 
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
 
 
- 
 
-