org.apache.hive.hcatalog.templeton.tool

Class JobStateTracker

java.lang.Object

org.apache.hive.hcatalog.templeton.tool.JobStateTracker

public class JobStateTracker
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
JobStateTracker(java.lang.String node, org.apache.zookeeper.ZooKeeper zk, boolean nodeIsTracker, java.lang.String job_trackingpath) Constructor for a new node -- takes the jobid of an existing job

Method Summary

Modifier and Type	Method and Description
void	create() Create the parent znode for this job state.
void	delete()
java.lang.String	getJobID() Get the jobid for this tracking node
static java.util.List<java.lang.String>	getTrackingJobs(Configuration conf, org.apache.zookeeper.ZooKeeper zk)
java.lang.String	makeTrackingJobZnode(java.lang.String nodename) Make a ZK path to an existing tracking node
java.lang.String	makeTrackingZnode() Make a ZK path to a new tracking node

Methods inherited from class java.lang.Object

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

Constructor Detail

JobStateTracker

public JobStateTracker(java.lang.String node,
                       org.apache.zookeeper.ZooKeeper zk,
                       boolean nodeIsTracker,
                       java.lang.String job_trackingpath)

Constructor for a new node -- takes the jobid of an existing job

Method Detail

create

public void create()
            throws java.io.IOException

Create the parent znode for this job state.

Throws:

java.io.IOException

delete

public void delete()
            throws java.io.IOException

Throws:

java.io.IOException

getJobID

public java.lang.String getJobID()
                          throws java.io.IOException

Get the jobid for this tracking node

Throws:

java.io.IOException

makeTrackingZnode

public java.lang.String makeTrackingZnode()

Make a ZK path to a new tracking node

makeTrackingJobZnode

public java.lang.String makeTrackingJobZnode(java.lang.String nodename)

Make a ZK path to an existing tracking node

getTrackingJobs

public static java.util.List<java.lang.String> getTrackingJobs(Configuration conf,
                                                               org.apache.zookeeper.ZooKeeper zk)
                                                        throws java.io.IOException

Throws:

java.io.IOException