edu.iu.dsc.tws.master.driver

Class ZKJobUpdater

java.lang.Object

edu.iu.dsc.tws.master.driver.ZKJobUpdater

public class ZKJobUpdater
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ZKJobUpdater(Config config)

Method Summary

Modifier and Type	Method and Description
boolean	removeInitialStateZNodes(java.lang.String jobID, int minWorkerID, int maxWorkerID) remove InitialState worker znodes after scaling down
void	updateJob(JobAPI.Job job) update Job on ZooKeeper

Methods inherited from class java.lang.Object

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

Constructor Detail

ZKJobUpdater

public ZKJobUpdater(Config config)

Method Detail

updateJob

public void updateJob(JobAPI.Job job)
               throws Twister2Exception

update Job on ZooKeeper

Parameters:

job -

Throws:

Twister2Exception

removeInitialStateZNodes

public boolean removeInitialStateZNodes(java.lang.String jobID,
                                        int minWorkerID,
                                        int maxWorkerID)

remove InitialState worker znodes after scaling down

Returns: