edu.iu.dsc.tws.common.zk

Class ZKEventsManager

java.lang.Object

edu.iu.dsc.tws.common.zk.ZKEventsManager

public final class ZKEventsManager
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 java.lang.String	constructEventPath(java.lang.String rootPath, java.lang.String jobID) construct the next event path increase the eventCounter by one
static void	createEventsZNode(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID) Create job znode for persistent states Assumes that there is no znode exists in the ZooKeeper This method should be called by the submitting client
static JobMasterAPI.JobEvent	decodeJobEvent(byte[] eventData)
static java.util.TreeMap<java.lang.Integer,JobMasterAPI.JobEvent>	getAllEvents(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID) return all registered events
static int	getNumberOfPastEvents(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID)
static void	initEventCounter(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID)
static void	publishEvent(CuratorFramework client, java.lang.String rootPath, java.lang.String jobID, JobMasterAPI.JobEvent jobEvent)

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

createEventsZNode

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

Create job znode for persistent states Assumes that there is no znode exists in the ZooKeeper This method should be called by the submitting client

initEventCounter

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

constructEventPath

public static java.lang.String constructEventPath(java.lang.String rootPath,
                                                  java.lang.String jobID)

construct the next event path increase the eventCounter by one

publishEvent

public static void publishEvent(CuratorFramework client,
                                java.lang.String rootPath,
                                java.lang.String jobID,
                                JobMasterAPI.JobEvent jobEvent)
                         throws Twister2Exception

Throws:

Twister2Exception

getNumberOfPastEvents

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

Throws:

Twister2Exception

decodeJobEvent

public static JobMasterAPI.JobEvent decodeJobEvent(byte[] eventData)
                                            throws InvalidProtocolBufferException

Throws:

InvalidProtocolBufferException

getAllEvents

public static java.util.TreeMap<java.lang.Integer,JobMasterAPI.JobEvent> getAllEvents(CuratorFramework client,
                                                                                      java.lang.String rootPath,
                                                                                      java.lang.String jobID)
                                                                               throws Twister2Exception

return all registered events

Throws:

Twister2Exception