edu.iu.dsc.tws.examples.utils

Class WordCountUtils

java.lang.Object

edu.iu.dsc.tws.examples.utils.WordCountUtils

public final class WordCountUtils
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static LogicalPlan	createWordCountPlan(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

Methods inherited from class java.lang.Object

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

Method Detail

createWordCountPlan

public static LogicalPlan createWordCountPlan(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