Class TaskPartitionerFixedsize
- java.lang.Object
- 
- org.apache.sysds.runtime.controlprogram.parfor.TaskPartitioner
- 
- org.apache.sysds.runtime.controlprogram.parfor.TaskPartitionerFixedsize
 
 
- 
- Direct Known Subclasses:
- TaskPartitionerNaive,- TaskPartitionerStatic
 
 public class TaskPartitionerFixedsize extends TaskPartitioner This naive task partitioner virtually iterates over the given FOR loop (from, to, incr), creates iterations and group them to tasks according to the given task size. There, all tasks are equally sized.
- 
- 
Constructor SummaryConstructors Constructor Description TaskPartitionerFixedsize(long taskSize, String iterVarName, IntObject fromVal, IntObject toVal, IntObject incrVal)
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description List<Task>createTasks()Creates and returns set of all tasks for given problem at once.longcreateTasks(LocalTaskQueue<Task> queue)Creates set of all tasks for given problem, but streams them directly into task queue.- 
Methods inherited from class org.apache.sysds.runtime.controlprogram.parfor.TaskPartitionergetNumIterations
 
- 
 
- 
- 
- 
Method Detail- 
createTaskspublic List<Task> createTasks() Description copied from class:TaskPartitionerCreates and returns set of all tasks for given problem at once.- Specified by:
- createTasksin class- TaskPartitioner
- Returns:
- list of tasks
 
 - 
createTaskspublic long createTasks(LocalTaskQueue<Task> queue) Description copied from class:TaskPartitionerCreates set of all tasks for given problem, but streams them directly into task queue. This allows for more tasks than fitting in main memory.- Specified by:
- createTasksin class- TaskPartitioner
- Parameters:
- queue- queue of takss
- Returns:
- ?
 
 
- 
 
-