/ - Diff - D-Net - D-Net project tracking tool

     package eu.dnetlib.data.hadoop.rmi;
     /**
      * Enum of the available HadoopBlackboardActions.
      */
     public enum HadoopBlackboardActions {
     	SUBMIT_MAPREDUCE_JOB, KILL_JOB, SUBMIT_OOZIE_JOB, IMPORT_EPR_HBASE, IMPORT_EPR_HDFS, DELETE_HDFS_PATH
     	/** The submit mapreduce job. */
     	SUBMIT_MAPREDUCE_JOB,
     	/** The kill job. */
     	KILL_JOB,
     	/** The submit oozie job. */
     	SUBMIT_OOZIE_JOB,
     	/** The import epr hbase. */
     	IMPORT_EPR_HBASE,
     	/** The import epr hdfs. */
     	IMPORT_EPR_HDFS,
     	/** The delete hdfs path. */
     	DELETE_HDFS_PATH
+    }

      * </pre>
+     *
      * @author claudio
+     *
      */
     @XmlRootElement
     public class HadoopJobDescriptor {
     	/** The id. */
     	private String id;
     	/** The job name. */
     	private String jobName;
     	/** The job description. */
     	private String jobDescription;
     	/** The status. */
     	private String status;
     	/** The start time. */
     	private String startTime;
     	/** The last activity. */
     	private String lastActivity;
     	/** The hadoop id. */
     	private String hadoopId;
     	/** The tracking url. */
     	private String trackingUrl;
     	/**
     	 * Instantiates a new hadoop job descriptor.
     	 */
     	public HadoopJobDescriptor() {}
     	public HadoopJobDescriptor(String jobName, String jobDescription, String id, String status, String startTime, String lastActivity, String hadoopId,
     			String trackingUrl) {
     	/**
     	 * Instantiates a new hadoop job descriptor.
+    	 *
     	 * @param jobName
     	 *            the job name
     	 * @param jobDescription
     	 *            the job description
     	 * @param id
     	 *            the id
     	 * @param status
     	 *            the status
     	 * @param startTime
     	 *            the start time
     	 * @param lastActivity
     	 *            the last activity
     	 * @param hadoopId
     	 *            the hadoop id
     	 * @param trackingUrl
     	 *            the tracking url
     	 */
     	public HadoopJobDescriptor(final String jobName, final String jobDescription, final String id, final String status, final String startTime,
     			final String lastActivity, final String hadoopId, final String trackingUrl) {
     		super();
     		this.id = id;
     		this.jobName = jobName;
-...
     		this.trackingUrl = trackingUrl;
+    	}
     	/**
     	 * Gets the job name.
+    	 *
     	 * @return the job name
     	 */
     	public String getJobName() {
     		return jobName;
+    	}
     	public void setJobName(String jobName) {
     	/**
     	 * Sets the job name.
+    	 *
     	 * @param jobName
     	 *            the new job name
     	 */
     	public void setJobName(final String jobName) {
     		this.jobName = jobName;
+    	}
     	/**
     	 * Gets the id.
+    	 *
     	 * @return the id
     	 */
     	public String getId() {
     		return id;
+    	}
     	public void setId(String id) {
     	/**
     	 * Sets the id.
+    	 *
     	 * @param id
     	 *            the new id
     	 */
     	public void setId(final String id) {
     		this.id = id;
+    	}
     	/**
     	 * Gets the job description.
+    	 *
     	 * @return the job description
     	 */
     	public String getJobDescription() {
     		return jobDescription;
+    	}
     	public void setJobDescription(String jobDescription) {
     	/**
     	 * Sets the job description.
+    	 *
     	 * @param jobDescription
     	 *            the new job description
     	 */
     	public void setJobDescription(final String jobDescription) {
     		this.jobDescription = jobDescription;
+    	}
     	/**
     	 * Gets the status.
+    	 *
     	 * @return the status
     	 */
     	public String getStatus() {
     		return status;
+    	}
     	public void setStatus(String status) {
     	/**
     	 * Sets the status.
+    	 *
     	 * @param status
     	 *            the new status
     	 */
     	public void setStatus(final String status) {
     		this.status = status;
+    	}
     	/**
     	 * Gets the start time.
+    	 *
     	 * @return the start time
     	 */
     	public String getStartTime() {
     		return startTime;
+    	}
     	public void setStartTime(String startTime) {
     	/**
     	 * Sets the start time.
+    	 *
     	 * @param startTime
     	 *            the new start time
     	 */
     	public void setStartTime(final String startTime) {
     		this.startTime = startTime;
+    	}
     	/**
     	 * Gets the last activity.
+    	 *
     	 * @return the last activity
     	 */
     	public String getLastActivity() {
     		return lastActivity;
+    	}
     	public void setLastActivity(String lastActivity) {
     	/**
     	 * Sets the last activity.
+    	 *
     	 * @param lastActivity
     	 *            the new last activity
     	 */
     	public void setLastActivity(final String lastActivity) {
     		this.lastActivity = lastActivity;
+    	}
     	/**
     	 * Gets the hadoop id.
+    	 *
     	 * @return the hadoop id
     	 */
     	public String getHadoopId() {
     		return hadoopId;
+    	}
     	public void setHadoopId(String hadoopId) {
     	/**
     	 * Sets the hadoop id.
+    	 *
     	 * @param hadoopId
     	 *            the new hadoop id
     	 */
     	public void setHadoopId(final String hadoopId) {
     		this.hadoopId = hadoopId;
+    	}
     	/**
     	 * Gets the tracking url.
+    	 *
     	 * @return the tracking url
     	 */
     	public String getTrackingUrl() {
     		return trackingUrl;
+    	}
     	public void setTrackingUrl(String trackingUrl) {
     	/**
     	 * Sets the tracking url.
+    	 *
     	 * @param trackingUrl
     	 *            the new tracking url
     	 */
     	public void setTrackingUrl(final String trackingUrl) {
     		this.trackingUrl = trackingUrl;
+    	}
+    }

     package eu.dnetlib.data.hadoop.rmi;
     /**
      * Enum of supported hadoop job types
      * Enum of supported hadoop job types.
+     *
      * @author claudio
+     *
      */
     public enum HadoopJobType {
     	mapreduce, oozie
     	/** The mapreduce. */
     	mapreduce,
     	/** The oozie. */
     	oozie
+    }

     import eu.dnetlib.common.rmi.RMIException;
     /**
      * The Class HadoopServiceException.
      */
     public class HadoopServiceException extends RMIException {
     	/** The Constant serialVersionUID. */
     	private static final long serialVersionUID = 7523999812098059764L;
     	/**
     	 * Instantiates a new hadoop service exception.
+    	 *
     	 * @param string
     	 *            the string
     	 */
     	private static final long serialVersionUID = 7523999812098059764L;
     	public HadoopServiceException(String string) {
     	public HadoopServiceException(final String string) {
     		super(string);
+    	}
     	public HadoopServiceException(String string, Throwable exception) {
     	/**
     	 * Instantiates a new hadoop service exception.
+    	 *
     	 * @param string
     	 *            the string
     	 * @param exception
     	 *            the exception
     	 */
     	public HadoopServiceException(final String string, final Throwable exception) {
     		super(string, exception);
+    	}
     	public HadoopServiceException(Throwable exception) {
     	/**
     	 * Instantiates a new hadoop service exception.
+    	 *
     	 * @param exception
     	 *            the exception
     	 */
     	public HadoopServiceException(final Throwable exception) {
     		super(exception);
+    	}

     import eu.dnetlib.common.rmi.BaseService;
     /**
      * The Interface HadoopService.
      */
     @WebService(targetNamespace = "http://services.dnetlib.eu/")
     public interface HadoopService extends BaseService {
     	/**
     	 * List available jobs.
+    	 *
     	 * @return the list
     	 * @throws HadoopServiceException
     	 *             the hadoop service exception
     	 */
     	List<String> listAvailableJobs() throws HadoopServiceException;
     	/**
     	 * List jobs.
+    	 *
     	 * @param clusterName
     	 *            the cluster name
     	 * @return the list
     	 * @throws HadoopServiceException
     	 *             the hadoop service exception
     	 */
     	List<HadoopJobDescriptor> listJobs(@WebParam(name = "clusterName") String clusterName) throws HadoopServiceException;
     	/**
     	 * Kill job.
+    	 *
     	 * @param jobId
     	 *            the job id
     	 * @return true, if successful
     	 * @throws HadoopServiceException
     	 *             the hadoop service exception
     	 */
     	boolean killJob(@WebParam(name = "id") String jobId) throws HadoopServiceException;
     	/**
     	 * List hbase tables.
+    	 *
     	 * @param clusterName
     	 *            the cluster name
     	 * @return the list
     	 * @throws HadoopServiceException
     	 *             the hadoop service exception
     	 */
     	List<String> listHbaseTables(@WebParam(name = "clusterName") String clusterName) throws HadoopServiceException;
     	/**
     	 * Ensure hbase table.
+    	 *
     	 * @param clusterName
     	 *            the cluster name
     	 * @param tableName
     	 *            the table name
     	 * @param columns
     	 *            the columns
     	 * @return true, if successful
     	 * @throws HadoopServiceException
     	 *             the hadoop service exception
     	 */
     	boolean ensureHbaseTable(@WebParam(name = "clusterName") String clusterName,
     			@WebParam(name = "tableName") String tableName,
     			@WebParam(name = "columns") Set<String> columns) throws HadoopServiceException;
     	/**
     	 * Creates the hbase table.
+    	 *
     	 * @param clusterName
     	 *            the cluster name
     	 * @param tableName
     	 *            the table name
     	 * @param columns
     	 *            the columns
     	 * @return true, if successful
     	 * @throws HadoopServiceException
     	 *             the hadoop service exception
     	 */
     	boolean createHbaseTable(@WebParam(name = "clusterName") String clusterName,
     			@WebParam(name = "tableName") String tableName,
     			@WebParam(name = "columns") Set<String> columns) throws HadoopServiceException;
     	/**
     	 * Truncate hbase table.
+    	 *
     	 * @param clusterName
     	 *            the cluster name
     	 * @param tableName
     	 *            the table name
     	 * @return true, if successful
     	 * @throws HadoopServiceException
     	 *             the hadoop service exception
     	 */
     	boolean truncateHbaseTable(@WebParam(name = "clusterName") String clusterName, @WebParam(name = "tableName") String tableName)
     			throws HadoopServiceException;
     	/**
     	 * Drop hbase table.
+    	 *
     	 * @param clusterName
     	 *            the cluster name
     	 * @param tableName
     	 *            the table name
     	 * @return true, if successful
     	 * @throws HadoopServiceException
     	 *             the hadoop service exception
     	 */
     	boolean dropHbaseTable(@WebParam(name = "clusterName") String clusterName, @WebParam(name = "tableName") String tableName) throws HadoopServiceException;
     	/**
     	 * Exist hbase table.
+    	 *
     	 * @param clusterName
     	 *            the cluster name
     	 * @param tableName
     	 *            the table name
     	 * @return true, if successful
     	 * @throws HadoopServiceException
     	 *             the hadoop service exception
     	 */
     	boolean existHbaseTable(@WebParam(name = "clusterName") String clusterName, @WebParam(name = "tableName") String tableName) throws HadoopServiceException;
+    }

Project

General

Profile

D-Net

Revision 28568

Added by Claudio Atzori over 10 years ago