org.apache.hive.hcatalog.templeton

Class CompleteDelegator

java.lang.Object

org.apache.hive.hcatalog.templeton.TempletonDelegator

org.apache.hive.hcatalog.templeton.CompleteDelegator

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 use 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

Constructor Summary

Constructors

Constructor and Description
CompleteDelegator(AppConfig appConf)

Method Summary

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

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(java.lang.String id)
                 throws CallbackFailedException,
                        java.io.IOException

Throws:

CallbackFailedException

java.io.IOException

doCallback

public static void doCallback(java.lang.String jobid,
                              java.lang.String url)
                       throws java.net.MalformedURLException,
                              java.io.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:

java.net.MalformedURLException

java.io.IOException