D-Net

package eu.dnetlib.msro.openaireplus.workflows.nodes;

import java.util.NoSuchElementException;

import org.apache.commons.logging.LogFactory;

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

import com.google.common.base.Joiner;

import com.google.common.base.Splitter;

import com.google.common.collect.Iterables;

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

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

	protected ConfigurationEnumerator configurationEnumerator;

	private UniqueServiceLocator serviceLocator;

	private String clusterName;

	private String clusterParam = "cluster";

	private String zkQuorumParam = "export_action_hbase_remote_zookeeper_quorum";

	private String zkPortParam = "export_action_hbase_remote_zookeeper_clientport";

	private String oozieWfAppPath;

	private String oozieWfAppPathParam = "oozie.wf.application.path";

	private String xqueryMdStoreService;

	private String mdStoreStoreLocationParam = "import_mdstore_service_location";

	private String objectStoreLocationParam = "import_content_object_store_location";

	private String islookupLocationParam = "import_islookup_service_location";

	private String importProjectConceptsContextIdParam = "import_project_concepts_context_id";

	private String importProjectConceptsContextId;

		token.getEnv().setAttribute(getClusterParam(), getClusterName());

		// Assumes we only have one mdStore service instance

		// Assumes we only have one objectStore service instance

		token.getEnv().setAttribute(getObjectStoreLocationParam(), getServiceEndpoint(getXqueryObjectStoreService()));

		token.getEnv().setAttribute(getImportProjectConceptsContextIdParam(), getImportProjectConceptsContextId());

		String zkPort = exportConf.get("hbase.zookeeper.property.clientPort");

		String zkQuorum = getZkQuorumCSV(exportConf, zkPort);

		token.getEnv().setAttribute(getZkQuorumParam(), zkQuorum);

		token.getEnv().setAttribute(getZkPortParam(), zkPort);

		String nameNode = conf.get("fs.defaultFS");

		token.getEnv().setAttribute("nameNode", nameNode);

		token.getEnv().setAttribute("jobTracker", conf.get("mapred.job.tracker"));

		token.getEnv().setAttribute(getOozieWfAppPathParam(), getURI(nameNode, getOozieWfAppPath()));

			throw new MSROException("unable to fetch service endpoint", e);

		} catch (NoSuchElementException e) {

			throw new MSROException("unable to find service endpoint, xquery: " + getXqueryMdStoreService(), e);

		} catch (IllegalArgumentException e) {

			throw new MSROException("more than one services found, we assume to have only one available", e);

		}

			throw new MSROException("unable to fetch profile id", e);

		} catch (NoSuchElementException e) {

			throw new MSROException("unable to find profile profile, xquery: " + xquery, e);

		} catch (IllegalArgumentException e) {

			throw new MSROException("more than one profile profiles was found, we assume to have only one available, xquery: " + xquery, e);

		}

	}

				log.warn("couldn't find any profile, xquery: " + xquery);

			}

			throw new MSROException("unable to fetch profile ids, x query: " + xquery, e);

		}

	}

		return asCSV(filter(getProfileIds(xquery), asList(getObjectStoreBlacklistCSV())));

	}

	protected List<String> filter(final List<String> list, final List<String> filter) {

		return list;

	}

	protected String asCSV(final List<String> list) {

		return Joiner.on(",").skipNulls().join(list);

	}

	protected List<String> asList(final String csv) {

		return Lists.newArrayList(Splitter.on(",").trimResults().omitEmptyStrings().split(csv));

	}

		return nameNode + relative;

	}

	}

	@Required

	}

	public String getXqueryMdStoreService() {

		return xqueryMdStoreService;

	}

	public String getMdStoreStoreLocationParam() {

		return mdStoreStoreLocationParam;

	}

	}

	public String getClusterName() {

		return clusterName;

	}

	}

	public String getZkQuorumParam() {

		return zkQuorumParam;

	}

	}

	public String getZkPortParam() {

		return zkPortParam;

	}

	}

	public String getClusterParam() {

		return clusterParam;

	}

	}

	public String getOozieWfAppPathParam() {

		return oozieWfAppPathParam;

	}

	}

	public String getOozieWfAppPath() {

		return oozieWfAppPath;

	}

	}

	public String getXqueryDatasetStore() {

		return xqueryDatasetStore;

	}

	}

	public String getMdStoreDatasetParam() {

		return mdStoreDatasetParam;

	}

	}

	public String getXqueryObjectStoreService() {

		return xqueryObjectStoreService;

	}

	@Required

	}

	public String getObjectStoreLocationParam() {

		return objectStoreLocationParam;

	}

	}

		return objectStoreBlacklistCSV;

	}

	public void setObjectStoreBlacklistCSV(final String objectStoreBlacklistCSV) {

		this.objectStoreBlacklistCSV = objectStoreBlacklistCSV;

	}

		return xqueryIsLookupService;

	}

	@Required

	public void setXqueryIsLookupService(final String xqueryIsLookupService) {

		this.xqueryIsLookupService = xqueryIsLookupService;

	}

	public String getIslookupLocationParam() {

		return islookupLocationParam;

	}

	public void setIslookupLocationParam(final String islookupLocationParam) {

		this.islookupLocationParam = islookupLocationParam;

	}

	public String getImportProjectConceptsContextIdParam() {

		return importProjectConceptsContextIdParam;

	}

	public void setImportProjectConceptsContextIdParam(final String importProjectConceptsContextIdParam) {

		this.importProjectConceptsContextIdParam = importProjectConceptsContextIdParam;

	}

	public String getImportProjectConceptsContextId() {

		return importProjectConceptsContextId;

	}

	public void setImportProjectConceptsContextId(final String importProjectConceptsContextId) {

		this.importProjectConceptsContextId = importProjectConceptsContextId;

	}