edu.iu.dsc.tws.examples.internal.jobmaster

Class JobMasterClientExample

java.lang.Object

edu.iu.dsc.tws.examples.internal.jobmaster.JobMasterClientExample

public final class JobMasterClientExample
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static java.util.Map<java.lang.String,java.lang.Integer>	generateAdditionalPorts(Config config, int workerPort) generate the additional requested ports for this worker
static java.util.List<java.lang.Integer>	getIDs(java.util.List<JobMasterAPI.WorkerInfo> workerList)
static void	main(java.lang.String[] args) a test class to run JMWorkerAgent First, a JobMaster instance should be started on a machine This client should connect to that server
static void	simulateClient(Config config, JobAPI.Job job, int workerID) a method to simulate JMWorkerAgent running in workers
static void	sleeeep(long duration)
static void	throwException(int workerID)
static Config	updateConfig(Config config1, Config config2, java.lang.String jmAddress) construct a Config object

Methods inherited from class java.lang.Object

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

Method Detail

main

public static void main(java.lang.String[] args)

a test class to run JMWorkerAgent First, a JobMaster instance should be started on a machine This client should connect to that server

It reads config files from conf/kubernetes directory It uses the first ComputeResource in that config file as the ComputeResource of this worker Number of workers is the number of workers in the first ComputeResource

When all workers joined, they get the full worker list Then, each worker sends a barrier message Then, each worker sends a completed message and closes

simulateClient

public static void simulateClient(Config config,
                                  JobAPI.Job job,
                                  int workerID)

a method to simulate JMWorkerAgent running in workers

throwException

public static void throwException(int workerID)

getIDs

public static java.util.List<java.lang.Integer> getIDs(java.util.List<JobMasterAPI.WorkerInfo> workerList)

updateConfig

public static Config updateConfig(Config config1,
                                  Config config2,
                                  java.lang.String jmAddress)

construct a Config object

generateAdditionalPorts

public static java.util.Map<java.lang.String,java.lang.Integer> generateAdditionalPorts(Config config,
                                                                                        int workerPort)

generate the additional requested ports for this worker

sleeeep

public static void sleeeep(long duration)