public class ZKJobUpdater
extends java.lang.Object
Constructor and Description |
---|
ZKJobUpdater(Config config,
java.lang.String jobID) |
Modifier and Type | Method and Description |
---|---|
boolean |
removeInitialStateZNodes(int minWorkerID,
int maxWorkerID)
remove InitialState worker znodes after scaling down
|
boolean |
updateState(JobAPI.JobState newState)
update number of workers on the Job on ZooKeeper
|
boolean |
updateWorkers(int workerChange)
update number of workers on the Job on ZooKeeper
|
public ZKJobUpdater(Config config, java.lang.String jobID)
public boolean updateState(JobAPI.JobState newState)
public boolean updateWorkers(int workerChange)
public boolean removeInitialStateZNodes(int minWorkerID, int maxWorkerID)