edu.iu.dsc.tws.rsched.schedulers.k8s.worker

Class K8sWorkerStarter

java.lang.Object

edu.iu.dsc.tws.rsched.schedulers.k8s.worker.K8sWorkerStarter

public final class K8sWorkerStarter
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static void	addShutdownHook(IWorkerStatusUpdater workerStatusUpdater) if the worker is killed by scaling down, we need to let ZooKeeper know about it and delete worker znode if zookeeper is used
static void	main(java.lang.String[] args)
static boolean	startWorker(IWorkerController workerController, IPersistentVolume pv) start the Worker class specified in conf files
static java.lang.String	updateJobMasterIp(java.lang.String jobMasterIP) update jobMasterIP if necessary if job master runs in client, jobMasterIP has to be provided as an environment variable that variable must be provided as a parameter to this method if job master runs as a separate pod, we get the job master IP address from its pod

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)

updateJobMasterIp

public static java.lang.String updateJobMasterIp(java.lang.String jobMasterIP)

update jobMasterIP if necessary if job master runs in client, jobMasterIP has to be provided as an environment variable that variable must be provided as a parameter to this method if job master runs as a separate pod, we get the job master IP address from its pod

Parameters:

jobMasterIP -

startWorker

public static boolean startWorker(IWorkerController workerController,
                                  IPersistentVolume pv)

start the Worker class specified in conf files

addShutdownHook

public static void addShutdownHook(IWorkerStatusUpdater workerStatusUpdater)

if the worker is killed by scaling down, we need to let ZooKeeper know about it and delete worker znode if zookeeper is used