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 TexecuteParallelMerge(int par)Merge all given input matrices in parallel into the given output matrix.abstract TexecuteSerialMerge()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
-
-