D-Net

{"type_source": "SVN", "goal": "package -U -T 4C source:jar", "url": "http://svn-public.driver.research-infrastructures.eu/driver/dnet45/modules/dnet-mapreduce-submitter/trunk/", "deploy_repository": "dnet45-snapshots", "version": "4", "mail": "sandro.labruzzo@isti.cnr.it,michele.artini@isti.cnr.it, claudio.atzori@isti.cnr.it, alessia.bardi@isti.cnr.it", "deploy_repository_url": "http://maven.research-infrastructures.eu/nexus/content/repositories/dnet45-snapshots", "name": "dnet-mapreduce-submitter"}

package eu.dnetlib.data.mapreduce;

import java.io.IOException;

import org.apache.hadoop.mapred.JobClient;

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

import org.springframework.context.annotation.Lazy;

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

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

/**

 * Factory bean for jobClient instances

 *

 * @author claudio

 *

 */

public class JobClientFactory {

	@Lazy

	@Autowired

	private ConfigurationEnumerator configurationEnumerator;

	public JobClient newInstance(final String name) throws IOException {

		return new JobClient(configurationEnumerator.get(ClusterName.valueOf(name)));

	}

}

package eu.dnetlib.data.mapreduce;

import java.util.Properties;

import org.apache.hadoop.mapreduce.Job;

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

/**

 * Interface for DNet mapreduce jobs

 * 

 * @author claudio

 * 

 */

public interface HadoopJob {

	/**

	 * @return job name

	 */

	public String getName();

	/**

	 * Sets the job params

	 * 

	 * @param p

	 *            job properties

	 * @return the job instance

	 */

	public Job setJobDetails(ClusterName clusterName, Properties p);

}

package eu.dnetlib.data.mapreduce;

import java.util.Map;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.springframework.beans.BeansException;

import org.springframework.beans.factory.BeanFactory;

import org.springframework.beans.factory.BeanFactoryAware;

import org.springframework.beans.factory.ListableBeanFactory;

import org.springframework.beans.factory.NoSuchBeanDefinitionException;

public class HadoopJobEnumerator implements BeanFactoryAware {

	private static final Log log = LogFactory.getLog(HadoopJobEnumerator.class); // NOPMD by marko on 11/24/08 5:02 PM

	/**

	 * bean factory.

	 */

	private ListableBeanFactory beanFactory;

	/**

	 * Get all beans implementing the ConfiguredJob interface.

	 * 

	 * @return

	 */

	@SuppressWarnings("unchecked")

	public Map<String, HadoopJob> getAll() {

		return beanFactory.getBeansOfType(HadoopJob.class);

	}

	@Override

	public void setBeanFactory(final BeanFactory beanFactory) throws BeansException {

		this.beanFactory = (ListableBeanFactory) beanFactory;

	}

	public ListableBeanFactory getBeanFactory() {

		return beanFactory;

	}

	/**

	 * Get given enableable or null.

	 * 

	 * @param name

	 * @return

	 */

	public HadoopJob get(final String name) {

		try {

			return (HadoopJob) beanFactory.getBean(name, HadoopJob.class);

		} catch (final NoSuchBeanDefinitionException e) {

			log.error("undefined bean: " + name, e);

			return null;

		}

	}

}

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"

	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">

	<bean id="hadoopJobEnumerator" class="eu.dnetlib.data.mapreduce.HadoopJobEnumerator" />

	<bean id="jobClientFactory" class="eu.dnetlib.data.mapreduce.JobClientFactory" />

</beans>

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

	<parent>

		<groupId>eu.dnetlib</groupId>

		<artifactId>dnet45-parent</artifactId>

		<version>1.0.0</version>

		<relativePath />

	</parent>

	<modelVersion>4.0.0</modelVersion>

	<groupId>eu.dnetlib</groupId>

	<artifactId>dnet-mapreduce-submitter</artifactId>

	<packaging>jar</packaging>

	<version>3.0.1</version>

	<scm>

	    <developerConnection>scm:svn:https://svn.driver.research-infrastructures.eu/driver/dnet45/modules/dnet-mapreduce-submitter/tags/dnet-mapreduce-submitter-3.0.1</developerConnection>

    </scm>

	<dependencies>

		<dependency>

			<groupId>eu.dnetlib</groupId>

			<artifactId>dnet-hadoop-commons</artifactId>

			<version>[2.0.0,3.0.0)</version>

		</dependency>

		<dependency>

			<groupId>org.springframework</groupId>

			<artifactId>spring-context-support</artifactId>

			<version>${spring.version}</version>

		</dependency>

	</dependencies>

</project>