Llamar a un trabajo de reducción de mapas desde un simple programa java
He estado tratando de llamar a un trabajo mapreduce desde un programa simple de Java en el mismo paquete ... Traté de referir el archivo jar mapreduce en mi programa java y llamarlo usando elrunJar(String args[])
método pasando también las rutas de entrada y salida para el trabajo mapreduce ... Pero el programa no funciona ...
¿Cómo ejecuto un programa de este tipo en el que solo uso la ruta de entrada, salida y jar de paso a su método principal? ¿Es posible ejecutar un trabajo mapreduce (jar) a través de él? Quiero hacer esto porque quiero ejecutar varios trabajos mapreduce uno tras otro donde mi programa Java vl llame a cada uno de esos trabajos haciendo referencia a su archivo jar. Si esto es posible, también podría usar un servlet simple para hacer tales llamadas y consulte sus archivos de salida para el propósito gráfico ..
/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/
/**
*
* @author root
*/
import org.apache.hadoop.util.RunJar;
import java.util.*;
public class callOther {
public static void main(String args[])throws Throwable
{
ArrayList arg=new ArrayList();
String output="/root/Desktp/output";
arg.add("/root/NetBeansProjects/wordTool/dist/wordTool.jar");
arg.add("/root/Desktop/input");
arg.add(output);
RunJar.main((String[])arg.toArray(new String[0]));
}
}