Easy to use API to connect and execute R scripts from Java. Also handles the timeouts well.
Usage: Add dist/rconnector as a dependency in project
Define spring bean or initialize it as a stand alone class
<bean class="com.leantaas.rconnector.RConnectionHandler" id="rConnectionHandler">
<property name="rServeHost" value="${r.serve.host:localhost}"/>
<property name="rServePort" value="${r.serve.port:6311}"/>
<property name="rScriptHomeDir" value="{r.scripts.home.directory:/opt/Rscripts/rProject/}"/>
<property name="timeoutInSec" value="${r.script.timeout:900}"></property>
</bean>
Inject in your Service You could either Autowire it or provide a setter method (or create a new instance)
@Autowired private RConnectionHandler rConnectionHandler;
Ready to use
//create input with input and output variables
RInput rIn = new RInput("opt_all.r");
rIn.getInputVarables().put("model_data", modelData);
rIn.getOutputVars().add("best_op");
rIn.getOutputVars().add("RELAXED");
rIn.getOutputVars().add("json_opt");
try {
//call R
ROutput rOut = rConnectionHandler.executeScript(rIn);
//read output
String[][] output = rOut.get("best_op").asStringMatrix();
Boolean relaxed = rOut.get("RELAXED").asBasic(Boolean.class);
String jsonOpt = rOut.get("json_opt").asString();
//process output
} catch (RTimedoutException rte) {
// this is a RuntimeException, catch if you want to do something with timed out requests
logger.warn("Request Timedout for: {}", rIn);
}
Note: Avoid using "setwd" in R scripts because Rserve start its own R session and working directory. "rconnector" paasses the "base_dir" with rScriptHomeDir as a value, we can make use of it for relative paths.
Coming soon:
YourPojo obj = rOut.get(“json_out”).asObject(YourPojo.class);
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent