edu.iu.dsc.tws.common.zk

Class ZKEphemStateManager

java.lang.Object

edu.iu.dsc.tws.common.zk.ZKEphemStateManager

public final class ZKEphemStateManager
extends java.lang.Object

Field Summary

Fields

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

Method Summary

Modifier and Type	Method and Description
static void	createEphemDir(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID) create parent directory for ephemeral worker znodes
static PersistentNode	createWorkerZnode(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID, int workerID)
static java.lang.String	decodeWorkerZnodeBody(byte[] body)
static void	removeEphemZNode(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID, int workerID) remove ephemeral worker znode from previous run if exist

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

DELETE_TAG

public static final java.lang.String DELETE_TAG

See Also:

Constant Field Values

Method Detail

createEphemDir

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

create parent directory for ephemeral worker znodes

createWorkerZnode

public static PersistentNode createWorkerZnode(CuratorFramework client,
                                               java.lang.String rootPath,
                                               java.lang.String jobID,
                                               int workerID)

removeEphemZNode

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

remove ephemeral worker znode from previous run if exist

Throws:

Twister2Exception

decodeWorkerZnodeBody

public static java.lang.String decodeWorkerZnodeBody(byte[] body)