public static WebHCatJTShim createInstance(final Configuration conf, final UserGroupInformation ugi)
      throws IOException {
    JobClient jc;
    try {
      jc = ugi.doAs(new PrivilegedExceptionAction<JobClient>() {
        public JobClient run() throws IOException, InterruptedException {
          //create this in doAs() so that it gets a security context based passed in 'ugi'
          return new JobClient(conf);
        }
      });
    } catch (InterruptedException ex) {
      throw new RuntimeException("Failed to create JobClient", ex);
    }
    return new WebHCatJTShim23(conf, jc);
  }
Create a connection to the Job Tracker.
shims/0.23/src/main/java/org/apache/hadoop/mapred/WebHCatJTShim23.java