JarCastingJPMML-Cascading 
PMML evaluator library for the [Cascading application framework] (http://www.cascading.org).
Features
- Full support for PMML specification versions 3.0 through 4.2. The evaluation is handled by the [JPMML-Evaluator] (https://github.com/jpmml/jpmml-evaluator) library.
Prerequisites
- Cascading application framework version 2.2.0 or greater.
Installation
Library
JPMML-Cascading library JAR file is released via [Maven Central Repository] (http://repo1.maven.org/maven2/org/jpmml/).
The current version is 1.2.2 (19 February, 2016).
<dependency>
<groupId>org.jpmml</groupId>
<artifactId>pmml-cascading</artifactId>
<version>1.2.2</version>
</dependency>
Example Hadoop job
Enter the project root directory and build using [Apache Maven] (http://maven.apache.org/):
mvn clean install
The build produces two JAR files:
pmml-cascading/target/pmml-cascading-1.2-SNAPSHOT.jar- Library JAR file.pmml-cascading-example/target/example-1.2-SNAPSHOT-job.jar- Example Hadoop job JAR file.
Usage
Library
Constructing an instance of Cascading planner class org.jpmml.cascading.PMMLPlanner based on a PMML document in local filesystem:
File pmmlFile = ...;
Evaluator evaluator = PMMLPlannerUtil.createEvaluator(pmmlFile);
PMMLPlanner pmmlPlanner = new PMMLPlanner(evaluator);
Building a simple flow for scoring data:
FlowDef flowDef = ...;
flowDef = flowDef.addSource("input", ...);
flowDef = flowDef.addSink("output", ...);
pmmlPlanner.setHeadName("input");
pmmlPlanner.setTailName("output");
flowDef = flowDef.addAssemblyPlanner(pmmlPlanner);
Please see [the example application] (https://github.com/jpmml/jpmml-cascading/blob/master/pmml-cascading-example/src/main/java/org/jpmml/cascading/Main.java) for full picture.
Example Hadoop job
The example Hadoop job JAR file contains a single executable class org.jpmml.cascading.Main.
This class expects three command-line arguments:
- The path of the model PMML file in local filesystem.
- The path of the Cascading source CSV resource in Hadoop filesystem.
- The path of the Cascading sink CSV resource in Hadoop filesystem.
For example:
hadoop jar example-1.2-SNAPSHOT-job.jar /tmp/cascading/model.pmml file:///tmp/cascading/input.csv file:///tmp/cascading/output
License
JPMML-Cascading is dual-licensed under the [GNU Affero General Public License (AGPL) version 3.0] (http://www.gnu.org/licenses/agpl-3.0.html) and a commercial license.
Additional information
Please contact [[email protected]] (mailto:[email protected])
