edu.iu.dsc.tws.common.zk

Class ZKBarrierManager

java.lang.Object

edu.iu.dsc.tws.common.zk.ZKBarrierManager

public final class ZKBarrierManager
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.logging.Logger	LOG

Method Summary

Modifier and Type	Method and Description
static void	createBarrierDir(CuratorFramework client, java.lang.String barrierDirPath) create parent directory for barrier
static void	createDefaultBarrierDir(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID) create parent directory for default barrier
static void	createInitBarrierDir(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID) create parent directory for init barrier
static void	createWorkerZNode(CuratorFramework client, java.lang.String workerPath, long timeout) create a worker znode at the barrier directory
static void	createWorkerZNodeAtDefault(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID, int workerID, long timeout) create a worker znode at the default barrier directory
static void	createWorkerZNodeAtInit(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID, int workerID, long timeout) create a worker znode at the init barrier directory
static void	deleteWorkerZNode(CuratorFramework client, java.lang.String workerPath) delete the worker znode at a barrier directory
static void	deleteWorkerZNodeFromDefault(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID, int workerID) delete the worker znode at the default barrier directory
static void	deleteWorkerZNodeFromInit(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID, int workerID) delete the worker znode at the init barrier directory
static boolean	existWorkerZNode(CuratorFramework client, java.lang.String workerPath) check existence of a worker znode at a barrier directory
static boolean	existWorkerZNodeAtDefault(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID, int workerID) check existence of a worker znode at the default barrier directory
static boolean	existWorkerZNodeAtInit(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID, int workerID) check existence of a worker znode at the init barrier directory
static int	getNumberOfWorkersAtBarrier(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID)
static long	readWorkerTimeout(CuratorFramework client, java.lang.String workerPath) read a worker znode at the barrier directory
static void	removeScaledDownZNodes(CuratorFramework client, java.lang.String barrierDir, int minID, int maxID) When a job is scaled down, we must delete the znodes of killed workers.
static void	removeScaledDownZNodes(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID, int minID, int maxID) Remove barrier znodes from both default and init barriers minID inclusive, maxID exclusive

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

Method Detail

createBarrierDir

public static void createBarrierDir(CuratorFramework client,
                                    java.lang.String barrierDirPath)

create parent directory for barrier

createDefaultBarrierDir

public static void createDefaultBarrierDir(CuratorFramework client,
                                           java.lang.String rootPath,
                                           java.lang.String jobID)

create parent directory for default barrier

createInitBarrierDir

public static void createInitBarrierDir(CuratorFramework client,
                                        java.lang.String rootPath,
                                        java.lang.String jobID)

create parent directory for init barrier

createWorkerZNode

public static void createWorkerZNode(CuratorFramework client,
                                     java.lang.String workerPath,
                                     long timeout)
                              throws Twister2Exception

create a worker znode at the barrier directory

Throws:

Twister2Exception

readWorkerTimeout

public static long readWorkerTimeout(CuratorFramework client,
                                     java.lang.String workerPath)
                              throws Twister2Exception

read a worker znode at the barrier directory

Throws:

Twister2Exception

createWorkerZNodeAtDefault

public static void createWorkerZNodeAtDefault(CuratorFramework client,
                                              java.lang.String rootPath,
                                              java.lang.String jobID,
                                              int workerID,
                                              long timeout)
                                       throws Twister2Exception

create a worker znode at the default barrier directory

Throws:

Twister2Exception

createWorkerZNodeAtInit

public static void createWorkerZNodeAtInit(CuratorFramework client,
                                           java.lang.String rootPath,
                                           java.lang.String jobID,
                                           int workerID,
                                           long timeout)
                                    throws Twister2Exception

create a worker znode at the init barrier directory

Throws:

Twister2Exception

deleteWorkerZNode

public static void deleteWorkerZNode(CuratorFramework client,
                                     java.lang.String workerPath)
                              throws Twister2Exception

delete the worker znode at a barrier directory

Throws:

Twister2Exception

deleteWorkerZNodeFromDefault

public static void deleteWorkerZNodeFromDefault(CuratorFramework client,
                                                java.lang.String rootPath,
                                                java.lang.String jobID,
                                                int workerID)
                                         throws Twister2Exception

delete the worker znode at the default barrier directory

Throws:

Twister2Exception

deleteWorkerZNodeFromInit

public static void deleteWorkerZNodeFromInit(CuratorFramework client,
                                             java.lang.String rootPath,
                                             java.lang.String jobID,
                                             int workerID)
                                      throws Twister2Exception

delete the worker znode at the init barrier directory

Throws:

Twister2Exception

existWorkerZNode

public static boolean existWorkerZNode(CuratorFramework client,
                                       java.lang.String workerPath)
                                throws Twister2Exception

check existence of a worker znode at a barrier directory

Throws:

Twister2Exception

existWorkerZNodeAtDefault

public static boolean existWorkerZNodeAtDefault(CuratorFramework client,
                                                java.lang.String rootPath,
                                                java.lang.String jobID,
                                                int workerID)
                                         throws Twister2Exception

check existence of a worker znode at the default barrier directory

Throws:

Twister2Exception

existWorkerZNodeAtInit

public static boolean existWorkerZNodeAtInit(CuratorFramework client,
                                             java.lang.String rootPath,
                                             java.lang.String jobID,
                                             int workerID)
                                      throws Twister2Exception

check existence of a worker znode at the init barrier directory

Throws:

Twister2Exception

removeScaledDownZNodes

public static void removeScaledDownZNodes(CuratorFramework client,
                                          java.lang.String barrierDir,
                                          int minID,
                                          int maxID)
                                   throws Twister2Exception

When a job is scaled down, we must delete the znodes of killed workers. minID inclusive, maxID exclusive

Throws:

Twister2Exception

removeScaledDownZNodes

public static void removeScaledDownZNodes(CuratorFramework client,
                                          java.lang.String rootPath,
                                          java.lang.String jobID,
                                          int minID,
                                          int maxID)
                                   throws Twister2Exception

Remove barrier znodes from both default and init barriers minID inclusive, maxID exclusive

Throws:

Twister2Exception

getNumberOfWorkersAtBarrier

public static int getNumberOfWorkersAtBarrier(CuratorFramework client,
                                              java.lang.String rootPath,
                                              java.lang.String jobID)
                                       throws Twister2Exception

Throws:

Twister2Exception