public class JobStateTracker
extends java.lang.Object
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
|
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
|
public JobStateTracker(java.lang.String node, org.apache.zookeeper.ZooKeeper zk, boolean nodeIsTracker, java.lang.String job_trackingpath)
public void create() throws java.io.IOException
java.io.IOException
public void delete() throws java.io.IOException
java.io.IOException
public java.lang.String getJobID() throws java.io.IOException
java.io.IOException
public java.lang.String makeTrackingZnode()
public java.lang.String makeTrackingJobZnode(java.lang.String nodename)
public static java.util.List<java.lang.String> getTrackingJobs(Configuration conf, org.apache.zookeeper.ZooKeeper zk) throws java.io.IOException
java.io.IOException
Copyright © 2012 The Apache Software Foundation