public class StatusDelegator extends TempletonDelegator
appConf
Constructor and Description |
---|
StatusDelegator(AppConfig appConf) |
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.
|
public StatusDelegator(AppConfig appConf)
public QueueStatusBean run(java.lang.String user, java.lang.String id) throws NotAuthorizedException, BadParam, java.io.IOException, java.lang.InterruptedException
NotAuthorizedException
BadParam
java.io.IOException
java.lang.InterruptedException
public static QueueStatusBean makeStatus(HadoopShims.WebHCatJTShim tracker, JobID jobid, java.lang.String childid, JobState state) throws BadParam, java.io.IOException
BadParam
java.io.IOException
public static QueueStatusBean makeStatus(HadoopShims.WebHCatJTShim tracker, JobID jobid, JobState state) throws BadParam, java.io.IOException
BadParam
java.io.IOException
Copyright © 2012 The Apache Software Foundation