Creating Custom Processors
About This Task
Using the SDK, you can create a custom processor and package it into a .jar file with all of its dependencies.
Steps
Create a new maven project using this maven pom file as an example.
To implement a custom processor, implement the following interface:
org.apache.streamline.streams.runtime.CustomProcessorRuntime
Package the .jar file with all dependencies:
mvn clean package mvn assembly:assembly
In the target directory you should have an uber jar that ends with
jar-with-dependencies.jar
. You need this jar file when you register your custom processor with SAM.
Example
The PhoenixEnrichmentProcessor is a good example of a new custom processor implementation.