DefaultHadoopSecurityManager.java

/*
 * Copyright 2011 LinkedIn, Inc
 *
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not
 * use this file except in compliance with the License. You may obtain a copy of
 * the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 * License for the specific language governing permissions and limitations under
 * the License.
 */

package azkaban.security;


import java.io.File;
import java.util.Properties;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.security.UserGroupInformation;
import org.apache.log4j.Logger;

import azkaban.utils.Props;

public class DefaultHadoopSecurityManager extends HadoopSecurityManager {

	private static final Logger logger = Logger.getLogger(DefaultHadoopSecurityManager.class);


	public DefaultHadoopSecurityManager() {
		logger.info("Default Hadoop Security Manager is used. Only do this on a non-hadoop cluster!");
	}
	
	@Override
	public UserGroupInformation getProxiedUser(String toProxy) throws SecurityManagerException {
		throw new SecurityManagerException("No real Hadoop Security Manager is set!");
	}

	/**
	* Create a proxied user, taking all parameters, including which user to proxy
	* from provided Properties.
	*/
	@Override
	public UserGroupInformation getProxiedUser(Props prop) throws SecurityManagerException {
		throw new SecurityManagerException("No real Hadoop Security Manager is set!");
	}

	@Override
	public boolean isHadoopSecurityEnabled() throws SecurityManagerException {
		throw new SecurityManagerException("No real Hadoop Security Manager is set!");
	}

	@Override
	public FileSystem getFSAsUser(String user) throws SecurityManagerException {
		throw new SecurityManagerException("No real Hadoop Security Manager is set!");
	}

	@Override
	public void prefetchToken(File tokenFile, String userToProxy)
			throws SecurityManagerException {
		// TODO Auto-generated method stub
		
	}

}