The experimental storm module aims to provide binary compatibility for Storm applications over Gearpump. That is to say, users could easily grab an existing Storm jar and run it on Gearpump. This documentation illustrates how to do so in a local Gearpump cluster.
launch a local cluster
bin/local
start a Gearpump Nimbus server
Users need server's address(nimbus.host
and nimbus.thrift.port
) to submit topologies later. The address is written to a yaml config file set with -output
option. Users can provide an existing config file where only the address will be overwritten. If not provided, a new file app.yaml
is created with the config.
bin/storm nimbus -output [conf <custom yaml config>]
submit Storm applications
Users can either submit Storm applications through command line or UI.
a. submit Storm applications through command line
bin/storm app -verbose -config app.yaml -jar storm-starter-${STORM_VERSION}.jar storm.starter.ExclamationTopology exclamation
Users are able to configure their applications through following options
jar
- set the path of a Storm application jarconfig
- submit the custom configuration file generated when launching Nimbusb. submit Storm application through UI
storm.starter.ExclamationTopology exclamation
as arguments.Either way, check the dashboard and you should see data flowing through your topology.