Class ResultMerge<T extends CacheableData<?>>
- java.lang.Object
-
- org.apache.sysds.runtime.controlprogram.parfor.ResultMerge<T>
-
- All Implemented Interfaces:
Serializable
- Direct Known Subclasses:
ResultMergeFrameLocalMemory
,ResultMergeMatrix
public abstract class ResultMerge<T extends CacheableData<?>> extends Object implements Serializable
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description ResultMerge(T out, T[] in, String outputFilename, boolean accum)
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description abstract T
executeParallelMerge(int par)
Merge all given input matrices in parallel into the given output matrix.abstract T
executeSerialMerge()
Merge all given input matrices sequentially into the given output matrix.
-
-
-
Method Detail
-
executeSerialMerge
public abstract T executeSerialMerge()
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.- Returns:
- output (merged) matrix
-
executeParallelMerge
public abstract T executeParallelMerge(int par)
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.- Parameters:
par
- degree of parallelism- Returns:
- output (merged) matrix
-
-