org.apache.hive.hcatalog.templeton

Class CompleteDelegator

java.lang.Object

org.apache.hive.hcatalog.templeton.TempletonDelegator

org.apache.hive.hcatalog.templeton.CompleteDelegator

@InterfaceAudience.Private
public class CompleteDelegator
extends TempletonDelegator

Complete a job. This will run the callback if - the job is done - there is a callback - the callback has not yet been called There is a small chance for a race condition if two callers run this at the same time. That should never happen. We use a Hadoop config var to notify this class on the completion of a job. Hadoop will call us multiple times in the event of failure. Even if the failure is that the client callback failed. See LauncherDelegator for the HADOOP_END_RETRY* vars that are set.

Field Summary

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

appConf, ARCHIVES, FILES

Constructor Summary

Constructors

Constructor and Description
CompleteDelegator(AppConfig appConf)

Method Summary

Modifier and Type	Method and Description
static void	doCallback(String jobid, String url) Call the callback url with the jobid to let them know it's finished.
CompleteBean	run(String id, String jobStatus)

Methods inherited from class java.lang.Object

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

Constructor Detail

CompleteDelegator

public CompleteDelegator(AppConfig appConf)

Method Detail

run

public CompleteBean run(String id,
                        String jobStatus)
                 throws CallbackFailedException,
                        IOException

Throws:

CallbackFailedException

IOException

doCallback

public static void doCallback(String jobid,
                              String url)
                       throws IOException

Call the callback url with the jobid to let them know it's finished. If the url has the string $jobId in it, it will be replaced with the completed jobid.

Throws:

IOException