edu.iu.dsc.tws.examples

Class Utils

java.lang.Object

edu.iu.dsc.tws.examples.Utils

public final class Utils
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static Option	createOption(java.lang.String opt, boolean hasArg, java.lang.String description, boolean required)
static LogicalPlan	createReduceTaskPlan(Config cfg, int workerID, java.util.List<JobMasterAPI.WorkerInfo> workerInfoList, int noOfTasks) Let assume we have 2 tasks per container and one additional for first container, which will be the destination
static LogicalPlan	createStageLogicalPlan(WorkerEnvironment workerEnv, java.util.List<java.lang.Integer> noOfTaskEachStage) Create task plan according to stages
static java.util.Set<java.lang.Integer>	getTasksOfExecutor(int exec, LogicalPlan plan, java.util.List<java.lang.Integer> noOfTaskEachStage, int stage)
static java.lang.String	printMap(java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>> map)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createReduceTaskPlan

public static LogicalPlan createReduceTaskPlan(Config cfg,
                                               int workerID,
                                               java.util.List<JobMasterAPI.WorkerInfo> workerInfoList,
                                               int noOfTasks)

Let assume we have 2 tasks per container and one additional for first container, which will be the destination

Returns:

task plan

printMap

public static java.lang.String printMap(java.util.Map<java.lang.Integer,java.util.Set<java.lang.Integer>> map)

createOption

public static Option createOption(java.lang.String opt,
                                  boolean hasArg,
                                  java.lang.String description,
                                  boolean required)

createStageLogicalPlan

public static LogicalPlan createStageLogicalPlan(WorkerEnvironment workerEnv,
                                                 java.util.List<java.lang.Integer> noOfTaskEachStage)

Create task plan according to stages

Parameters:

workerEnv - worker environment

noOfTaskEachStage - no of tasks at each stage

Returns:

task plan

getTasksOfExecutor

public static java.util.Set<java.lang.Integer> getTasksOfExecutor(int exec,
                                                                  LogicalPlan plan,
                                                                  java.util.List<java.lang.Integer> noOfTaskEachStage,
                                                                  int stage)