edu.iu.dsc.tws.examples.internal.rsched

Class BasicK8sWorker

java.lang.Object

edu.iu.dsc.tws.examples.internal.rsched.BasicK8sWorker

All Implemented Interfaces:

IReceiverFromDriver, IScalerListener, IWorker

public class BasicK8sWorker
extends java.lang.Object
implements IWorker, IScalerListener, IReceiverFromDriver

Constructor Summary

Constructors

Constructor and Description
BasicK8sWorker()

Method Summary

Modifier and Type	Method and Description
void	driverMessageReceived(Any anyMessage) received a broadcast message from the driver
static void	echoServer(JobMasterAPI.WorkerInfo workerInfo) an echo server.
void	execute(Config config, JobAPI.Job job, IWorkerController workerController, IPersistentVolume persistentVolume, IVolatileVolume volatileVolume) Execute with the resources configured
void	listHdfsDir() a method to test hdfs access from workers
void	printWorkersPerNode(java.util.Map<java.lang.String,java.util.List<JobMasterAPI.WorkerInfo>> workersPerNode)
void	sleepRandomTime(long maxTimeMS) a test method to make the worker wait some time
static void	sleepSomeTime(java.lang.String id, long sleepSeconds) a test method to make the worker wait some time
void	workersScaledDown(int instancesRemoved) called when new instances of workers are removed from the job
void	workersScaledUp(int instancesAdded) called when new instances of workers are added the job

Methods inherited from class java.lang.Object

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

Constructor Detail

BasicK8sWorker

public BasicK8sWorker()

Method Detail

execute

public void execute(Config config,
                    JobAPI.Job job,
                    IWorkerController workerController,
                    IPersistentVolume persistentVolume,
                    IVolatileVolume volatileVolume)

Description copied from interface: IWorker

Execute with the resources configured

Specified by:

execute in interface IWorker

Parameters:

config - configuration

job - the worker id

workerController - the worker controller

persistentVolume - information about persistent file system

volatileVolume - information about volatile file system

workersScaledUp

public void workersScaledUp(int instancesAdded)

Description copied from interface: IScalerListener

called when new instances of workers are added the job

Specified by:

workersScaledUp in interface IScalerListener

workersScaledDown

public void workersScaledDown(int instancesRemoved)

Description copied from interface: IScalerListener

called when new instances of workers are removed from the job

Specified by:

workersScaledDown in interface IScalerListener

driverMessageReceived

public void driverMessageReceived(Any anyMessage)

Description copied from interface: IReceiverFromDriver

received a broadcast message from the driver

Specified by:

driverMessageReceived in interface IReceiverFromDriver

Parameters:

anyMessage - received message from the driver

echoServer

public static void echoServer(JobMasterAPI.WorkerInfo workerInfo)

an echo server.

sleepSomeTime

public static void sleepSomeTime(java.lang.String id,
                                 long sleepSeconds)

a test method to make the worker wait some time

sleepRandomTime

public void sleepRandomTime(long maxTimeMS)

a test method to make the worker wait some time

printWorkersPerNode

public void printWorkersPerNode(java.util.Map<java.lang.String,java.util.List<JobMasterAPI.WorkerInfo>> workersPerNode)

listHdfsDir

public void listHdfsDir()

a method to test hdfs access from workers