org.apache.hive.hcatalog.templeton.tool

Class JobState

java.lang.Object

org.apache.hive.hcatalog.templeton.tool.JobState

public class JobState
extends Object

The persistent state of a job. The state is stored in one of the supported storage systems.

Constructor Summary

Constructors

Constructor and Description
JobState(String id, org.apache.hadoop.conf.Configuration conf)

Method Summary

Methods

Modifier and Type	Method and Description
void	addChild(String jobid) Add a jobid to the list of children of this job.
void	close() For storage methods that require a connection, this is a hint that it's time to close the connection.
void	delete()
String	getCallback() The url callback
List<JobState>	getChildren() Get a list of jobstates for jobs that are children of this job.
String	getCompleteStatus() The status of a job once it is completed.
Long	getCreated() When this job was created.
Long	getExitValue() The system exit value of the job.
String	getField(String name)
String	getId() This job id.
static List<String>	getJobs(org.apache.hadoop.conf.Configuration conf) Get an id for each currently existing job, which can be used to create a JobState object.
Long	getLongField(String name) Fetch an integer field from the store.
Long	getNotifiedTime() The time when the callback was sent.
String	getParent()
String	getPercentComplete() The percent complete of a job
static TempletonStorage	getStorage(org.apache.hadoop.conf.Configuration conf) Get an open instance of the selected storage class.
static TempletonStorage	getStorageInstance(org.apache.hadoop.conf.Configuration conf) Get an instance of the selected storage class.
String	getUser() The user who started this job.
Map<String,Object>	getUserArgs()
void	setCallback(String callback)
void	setCompleteStatus(String complete)
void	setCreated(long created)
void	setExitValue(long exitValue)
void	setField(String name, String val) Store a String field from the store.
void	setLongField(String name, long val) Store a long field.
void	setNotifiedTime(long notified)
void	setParent(String id) Set parent job of this job
void	setPercentComplete(String percent)
void	setUser(String user)
void	setUserArgs(Map<String,Object> userArgs)

Methods inherited from class java.lang.Object

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

Constructor Detail

JobState

public JobState(String id,
        org.apache.hadoop.conf.Configuration conf)
         throws IOException

Throws:

IOException

Method Detail

delete

public void delete()
            throws IOException

Throws:

IOException

getStorageInstance

public static TempletonStorage getStorageInstance(org.apache.hadoop.conf.Configuration conf)

Get an instance of the selected storage class. Defaults to HDFS storage if none is specified.

getStorage

public static TempletonStorage getStorage(org.apache.hadoop.conf.Configuration conf)
                                   throws IOException

Get an open instance of the selected storage class. Defaults to HDFS storage if none is specified.

Throws:

IOException

close

public void close()
           throws IOException

For storage methods that require a connection, this is a hint that it's time to close the connection.

Throws:

IOException

getId

public String getId()

This job id.

getPercentComplete

public String getPercentComplete()
                          throws IOException

The percent complete of a job

Throws:

IOException

setPercentComplete

public void setPercentComplete(String percent)
                        throws IOException

Throws:

IOException

addChild

public void addChild(String jobid)
              throws IOException

Add a jobid to the list of children of this job.

Parameters:

jobid -

Throws:

IOException

setParent

public void setParent(String id)
               throws IOException

Set parent job of this job

Parameters:

id -

Throws:

IOException

getParent

public String getParent()
                 throws IOException

Throws:

IOException

getChildren

public List<JobState> getChildren()
                           throws IOException

Get a list of jobstates for jobs that are children of this job.

Throws:

IOException

getExitValue

public Long getExitValue()
                  throws IOException

The system exit value of the job.

Throws:

IOException

setExitValue

public void setExitValue(long exitValue)
                  throws IOException

Throws:

IOException

getCreated

public Long getCreated()
                throws IOException

When this job was created.

Throws:

IOException

setCreated

public void setCreated(long created)
                throws IOException

Throws:

IOException

getUser

public String getUser()
               throws IOException

The user who started this job.

Throws:

IOException

setUser

public void setUser(String user)
             throws IOException

Throws:

IOException

getUserArgs

public Map<String,Object> getUserArgs()
                               throws IOException

Throws:

IOException

setUserArgs

public void setUserArgs(Map<String,Object> userArgs)
                 throws IOException

Throws:

IOException

getCallback

public String getCallback()
                   throws IOException

The url callback

Throws:

IOException

setCallback

public void setCallback(String callback)
                 throws IOException

Throws:

IOException

getCompleteStatus

public String getCompleteStatus()
                         throws IOException

The status of a job once it is completed.

Throws:

IOException

setCompleteStatus

public void setCompleteStatus(String complete)
                       throws IOException

Throws:

IOException

getNotifiedTime

public Long getNotifiedTime()
                     throws IOException

The time when the callback was sent.

Throws:

IOException

setNotifiedTime

public void setNotifiedTime(long notified)
                     throws IOException

Throws:

IOException

getLongField

public Long getLongField(String name)
                  throws IOException

Fetch an integer field from the store.

Throws:

IOException

setField

public void setField(String name,
            String val)
              throws IOException

Store a String field from the store.

Throws:

IOException

getField

public String getField(String name)
                throws IOException

Throws:

IOException

setLongField

public void setLongField(String name,
                long val)
                  throws IOException

Store a long field.

Parameters:

name -

val -

Throws:

IOException

getJobs

public static List<String> getJobs(org.apache.hadoop.conf.Configuration conf)
                            throws IOException

Get an id for each currently existing job, which can be used to create a JobState object.

Parameters:

conf -

Throws:

IOException