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. There are three sources of the info 1. Query result from JobTracker 2. JobState saved by TempletonControllerJob when monitoring the TempletonControllerJob 3. TempletonControllerJob put a JobState for every job it launches, so child job can retrieve its parent job by its JobState Currently there is no permission restriction, any user can query any job

Field Summary

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

appConf, ARCHIVES, FILES

Constructor Summary

Constructors

Constructor and Description
StatusDelegator(AppConfig appConf)

Method Summary

Methods

Modifier and Type	Method and Description
QueueStatusBean	run(String user, String id)
static org.apache.hadoop.mapred.JobID	StringToJobID(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(String user,
                  String id)
                    throws NotAuthorizedException,
                           BadParam,
                           IOException,
                           InterruptedException

Throws:

NotAuthorizedException

BadParam

IOException

InterruptedException

StringToJobID

public static org.apache.hadoop.mapred.JobID StringToJobID(String id)
                                                    throws BadParam

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

Throws:

BadParam