Hortonworks Streaming Analytics Manager User Guide
Also available as:
PDF

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

  1. Create a new maven project using this maven pom file as an example.

  2. To implement a custom processor, implement the following interface:

    org.apache.streamline.streams.runtime.CustomProcessorRuntime
  3. Package the .jar file with all dependencies:

    mvn clean package
    mvn assembly:assembly
  4. 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.