001 /** 002 * Licensed to the Apache Software Foundation (ASF) under one 003 * or more contributor license agreements. See the NOTICE file 004 * distributed with this work for additional information 005 * regarding copyright ownership. The ASF licenses this file 006 * to you under the Apache License, Version 2.0 (the 007 * "License"); you may not use this file except in compliance 008 * with the License. You may obtain a copy of the License at 009 * 010 * http://www.apache.org/licenses/LICENSE-2.0 011 * 012 * Unless required by applicable law or agreed to in writing, software 013 * distributed under the License is distributed on an "AS IS" BASIS, 014 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 015 * See the License for the specific language governing permissions and 016 * limitations under the License. 017 */ 018 package org.apache.oozie.action.hadoop; 019 020 import java.util.concurrent.Callable; 021 022 //TODO this class goes away when doing 20.100+ only 023 024 //TODO this class is for testing, but is here to allow selective compilation 025 public class DoAs implements Callable<Void> { 026 private String user; 027 private Callable<Void> callable; 028 029 public void setUser(String user) { 030 this.user = user; 031 } 032 033 protected String getUser() { 034 return user; 035 } 036 037 protected Callable<Void> getCallable() { 038 return callable; 039 } 040 041 public void setCallable(Callable<Void> callable) { 042 this.callable = callable; 043 } 044 045 public Void call() throws Exception { 046 callable.call(); 047 return null; 048 } 049 050 public static void call(String user, Callable<Void> callable) throws Exception { 051 Class klass; 052 try { 053 klass = Class.forName("org.apache.oozie.action.hadoop.KerberosDoAs"); 054 } 055 catch (ClassNotFoundException ex) { 056 klass = DoAs.class; 057 } 058 DoAs doAs = (DoAs) klass.newInstance(); 059 doAs.setCallable(new Callable<Void>() { 060 @Override 061 public Void call() throws Exception { 062 PigMain.main(null); 063 return null; 064 } 065 }); 066 doAs.setUser(user); 067 doAs.setCallable(callable); 068 doAs.call(); 069 } 070 071 }