org.apache.hive.hcatalog.templeton

Class StatusDelegator

java.lang.Object

org.apache.hive.hcatalog.templeton.TempletonDelegator

org.apache.hive.hcatalog.templeton.StatusDelegator

public class StatusDelegator
extends TempletonDelegator

Fetch the status of a given job id in the queue.

Field Summary

Fields inherited from class org.apache.hive.hcatalog.templeton.TempletonDelegator

appConf

Constructor Summary

Constructors

Constructor and Description
StatusDelegator(AppConfig appConf)

Method Summary

Modifier and Type	Method and Description
static QueueStatusBean	makeStatus(HadoopShims.WebHCatJTShim tracker, JobID jobid, JobState state)
static QueueStatusBean	makeStatus(HadoopShims.WebHCatJTShim tracker, JobID jobid, java.lang.String childid, JobState state)
QueueStatusBean	run(java.lang.String user, java.lang.String id)
static JobID	StringToJobID(java.lang.String id) A version of JobID.forName with our app specific error handling.

Methods inherited from class java.lang.Object

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

Constructor Detail

StatusDelegator

public StatusDelegator(AppConfig appConf)

Method Detail

run

public QueueStatusBean run(java.lang.String user,
                           java.lang.String id)
                    throws NotAuthorizedException,
                           BadParam,
                           java.io.IOException,
                           java.lang.InterruptedException

Throws:

NotAuthorizedException

BadParam

java.io.IOException

java.lang.InterruptedException

makeStatus

public static QueueStatusBean makeStatus(HadoopShims.WebHCatJTShim tracker,
                                         JobID jobid,
                                         java.lang.String childid,
                                         JobState state)
                                  throws BadParam,
                                         java.io.IOException

Throws:

BadParam

java.io.IOException

makeStatus

public static QueueStatusBean makeStatus(HadoopShims.WebHCatJTShim tracker,
                                         JobID jobid,
                                         JobState state)
                                  throws BadParam,
                                         java.io.IOException

Throws:

BadParam

java.io.IOException

StringToJobID

public static JobID StringToJobID(java.lang.String id)
                           throws BadParam

A version of JobID.forName with our app specific error handling.

Throws:

BadParam