Apache Storm Streamer

Import Ignite Storm Streamer Module In Maven Project. If you are using Maven to manage dependencies of your project, you can add Storm module dependency like this (replace ${ignite-storm-ext.version} with actual Ignite Storm Extension version you are interested in):

<project xmlns="http://maven.apache.org/POM/4.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
                        http://maven.apache.org/xsd/maven-4.0.0.xsd">
    ...
    <dependencies>
        ...
        <dependency>
            <groupId>org.apache.ignite</groupId>
            <artifactId>ignite-storm-ext</artifactId>
            <version>${ignite-storm-ext.version}</version>
        </dependency>
        ...
    </dependencies>
    ...
</project>

Create an Ignite configuration file (see example-ignite.xml in modules/storm/src/test/resources/example-ignite.xml) and make sure it is accessible from the streamer.

Make sure your key-value data input to the streamer is specified with the field named ignite (or a different one you configure with StormStreamer.setIgniteTupleField(…​)). See TestStormSpout.declareOutputFields(…​) for an example.

Create a topology with the streamer, make a jar file with all dependencies and run the following

storm jar ignite-storm-streaming-jar-with-dependencies.jar my.company.ignite.MyStormTopology