edu.iu.dsc.tws.master.server

Class ZKMasterController

java.lang.Object

edu.iu.dsc.tws.master.server.ZKMasterController

All Implemented Interfaces:

IWorkerEventSender

public class ZKMasterController
extends java.lang.Object
implements IWorkerEventSender

Field Summary

Fields

Modifier and Type	Field and Description
protected CuratorFramework	client
protected Config	config
protected PathChildrenCache	ephemChildrenCache
protected java.lang.String	ephemDir
protected java.lang.String	jobID
static java.util.logging.Logger	LOG
protected int	numberOfWorkers
protected PathChildrenCache	persChildrenCache
protected java.lang.String	persDir
protected java.lang.String	rootPath

Constructor Summary

Constructors

Constructor and Description
ZKMasterController(Config config, java.lang.String jobID, int numberOfWorkers, java.lang.String jmAddress, WorkerMonitor workerMonitor)

Method Summary

Modifier and Type	Method and Description
void	allJoined() all workers joined the job
void	close() close all local entities.
void	initialize(JobMasterState initialState) initialize ZKMasterController, create znode children caches for job master to watch proper events
void	jmRestarted()
void	jobScaled(int change, int numberOfWorkers1) job scaled up or down
void	workerFailed(int workerID) the worker with the provided workerID failed
void	workerRestarted(JobMasterAPI.WorkerInfo workerInfo) the worker with the provided workerInfo restarted

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final java.util.logging.Logger LOG

numberOfWorkers

protected int numberOfWorkers

jobID

protected java.lang.String jobID

config

protected Config config

rootPath

protected java.lang.String rootPath

persDir

protected java.lang.String persDir

ephemDir

protected java.lang.String ephemDir

client

protected CuratorFramework client

ephemChildrenCache

protected PathChildrenCache ephemChildrenCache

persChildrenCache

protected PathChildrenCache persChildrenCache

Constructor Detail

ZKMasterController

public ZKMasterController(Config config,
                          java.lang.String jobID,
                          int numberOfWorkers,
                          java.lang.String jmAddress,
                          WorkerMonitor workerMonitor)

Method Detail

initialize

public void initialize(JobMasterState initialState)
                throws Twister2Exception

initialize ZKMasterController, create znode children caches for job master to watch proper events

Throws:

Twister2Exception

workerFailed

public void workerFailed(int workerID)

Description copied from interface: IWorkerEventSender

the worker with the provided workerID failed

Specified by:

workerFailed in interface IWorkerEventSender

workerRestarted

public void workerRestarted(JobMasterAPI.WorkerInfo workerInfo)

Description copied from interface: IWorkerEventSender

the worker with the provided workerInfo restarted

Specified by:

workerRestarted in interface IWorkerEventSender

allJoined

public void allJoined()

Description copied from interface: IWorkerEventSender

all workers joined the job

Specified by:

allJoined in interface IWorkerEventSender

jobScaled

public void jobScaled(int change,
                      int numberOfWorkers1)

Description copied from interface: IWorkerEventSender

job scaled up or down

Specified by:

jobScaled in interface IWorkerEventSender

jmRestarted

public void jmRestarted()

close

public void close()

close all local entities.