Difference between revisions of "SoBigData: step-by-step procedure for algorithm integration"

package app.template;
 
import java.io.BufferedReader;
import java.io.InputStreamReader;
 
import org.gcube.dataanalysis.ecoengine.datatypes.PrimitiveType;
import org.gcube.dataanalysis.ecoengine.datatypes.StatisticalType;
import org.gcube.dataanalysis.ecoengine.datatypes.enumtypes.PrimitiveTypes;
import org.gcube.dataanalysis.ecoengine.interfaces.StandardLocalExternalAlgorithm;
 
/**
 * Hello world!
 *
 */
public class App extends StandardLocalExternalAlgorithm{
 
	public static final String test_string_name="test_string";
	public static final String resultKey = "result";
	private String result = null;
 
	@Override
	public String getDescription() {
		//RETURN A STRING WITH THE DESCRIPTION OF YOUR ALGORITHM
		return null;
	}
 
	@Override
	public void init() throws Excepa]tion {
		//IF YOU NEED TO DO SOMETHING BEFORE THE EXECUTION.
 
	}
 
	@Override
	protected void process() throws Exception {
 
		//READ THE INPUTS
		String test_string = getInputParameter(test_string_name);
		System.out.println("Input: "+test_string);
 
		//YOUR ALGORITHM MUST BE HERE!
		result = test_string+" (OK)";
 
		//<== START - EXAMPLE OF HOW TO CALL A PHYTON SCRIPT ==>
//		String pythonCmd = getInputParameter("python_location");   
//		ProcessBuilder pb = new ProcessBuilder(pythonCmd, "param1", "param2", ...);
//		Process pr = pb.start();
//
//		BufferedReader stdOutput = new BufferedReader(new InputStreamReader(pr.getInputStream()));
//	    BufferedReader stdError = new BufferedReader(new InputStreamReader(pr.getErrorStream()));
//	    String stdReader = null;
//	    while((stdReader = stdOutput.readLine())!=null) {
//	        System.out.println(stdReader);
//	    }
//	    while((stdReader = stdError.readLine())!=null) {
//	        System.out.println(stdReader);
//	    }
		//<== END - EXAMPLE OF HOW TO CALL A PHYTON SCRIPT ==>
 
	}
 
	@Override
	protected void setInputParameters() {
		//YOU MUST DEFINE YOUR INPUTS
		addStringInput(test_string_name, "Description", "DefaultInput");
	}
 
	@Override
	public void shutdown() {
		//SOME OPERATION AT THE END OF THE PROCESS		
	}
 
 
	@Override
	public StatisticalType getOutput() {
	   PrimitiveType val = new PrimitiveType(String.class.getName(), result , PrimitiveTypes.STRING, resultKey, "This is the result of my algorithm");
	   System.out.println("Output: "+result);
	   return val;
	}
 
 
}

package app.template;
 
import java.util.List;
 
import org.gcube.dataanalysis.ecoengine.configuration.AlgorithmConfiguration;
import org.gcube.dataanalysis.ecoengine.interfaces.ComputationalAgent;
import org.gcube.dataanalysis.ecoengine.processing.factories.TransducerersFactory;
import org.gcube.dataanalysis.ecoengine.test.regression.Regressor;
 
public class Test_App {
 
	private static AlgorithmConfiguration testConfigLocal() {
 
		AlgorithmConfiguration config = Regressor.getConfig();
		 config.setAgent("APP");
		 config.setParam(App.test_string_name, "HELLO WORLD?");
		 //config.setParam("python_location", "/Library/Frameworks/Python.framework/Versions/2.7/bin/python";);
 
		return config;
	}		
 
	public static void main(String[] args) throws Exception {
		List<ComputationalAgent> trans = null;
		trans = TransducerersFactory.getTransducerers(testConfigLocal());
		trans.get(0).init();
		Regressor.process(trans.get(0));
		trans.get(0).getOutput();
		trans = null;
		}	
 
}