org.apache.hive.hcatalog.templeton.tool

Class JobStateTracker

java.lang.Object

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

public class JobStateTracker
extends Object

Constructor Summary

Constructors

Constructor and Description
JobStateTracker(String node, org.apache.curator.framework.CuratorFramework zk, boolean nodeIsTracker, String job_trackingpath) Constructor for a new node -- takes the jobid of an existing job

Method Summary

Methods

Modifier and Type	Method and Description
void	create() Create the parent znode for this job state.
void	delete()
String	getJobID() Get the jobid for this tracking node
static List<String>	getTrackingJobs(org.apache.hadoop.conf.Configuration conf, org.apache.curator.framework.CuratorFramework zk)
String	makeTrackingJobZnode(String nodename) Make a ZK path to an existing tracking node
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(String node,
               org.apache.curator.framework.CuratorFramework zk,
               boolean nodeIsTracker,
               String job_trackingpath)

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

Method Detail

create

public void create()
            throws IOException

Create the parent znode for this job state.

Throws:

IOException

delete

public void delete()
            throws IOException

Throws:

IOException

getJobID

public String getJobID()
                throws IOException

Get the jobid for this tracking node

Throws:

IOException

makeTrackingZnode

public String makeTrackingZnode()

Make a ZK path to a new tracking node

makeTrackingJobZnode

public String makeTrackingJobZnode(String nodename)

Make a ZK path to an existing tracking node

getTrackingJobs

public static List<String> getTrackingJobs(org.apache.hadoop.conf.Configuration conf,
                           org.apache.curator.framework.CuratorFramework zk)
                                    throws IOException

Throws:

IOException