Code Snippet for Hooking Java Drivers in Oozie

oozie-java-driver-hook

public class DriverHook implements Runnable{
static public DriverHookNewApi create(Job job){
return new DriverHookNewApi(job); }
Job job;
private DriverHookNewApi(Job job){
this.job = job; }
public void run(){
System.out.println("Hello from MyHook");
if(job == null)
throw new NullPointerException("err msg");
try{
JobID hdpJobID = job.getJobID(); if(!job.isComplete())
job.killJob();
}
catch (IOException e){
}
} }


Runnable myHook = DriverHook.create(job); Thread hookThr = new Thread(myHook); Runtime.getRuntime().addShutdownHook(hookThr);