D-Net

package eu.dnetlib.data.hadoop;

import eu.dnetlib.data.hadoop.config.ConfigurationEnumerator;

import eu.dnetlib.data.hadoop.rmi.HadoopServiceException;

import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpException;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.springframework.beans.factory.annotation.Autowired;

public abstract class AbstractHadoopClient {

	private static final Log log = LogFactory.getLog(AbstractHadoopClient.class);

	@Autowired

	private ISClient isClient;

	@Autowired

	protected ConfigurationEnumerator configurationEnumerator;

	protected void setHadoopUser() throws HadoopServiceException {

		setHadoopUser(getDefaultUser());

	}

	private String getDefaultUser() throws HadoopServiceException {

		try {

			return isClient.queryForServiceProperty("default.hadoop.user");

		} catch (ISLookUpException e) {

			throw new HadoopServiceException(e);

		}

	}

	protected void setHadoopUser(final String userName) {

		log.info("setting HADOOP_USER_NAME as " + userName);

		System.setProperty("HADOOP_USER_NAME", userName);

	}

}