This lab asks you to try and set up a simple Storm topology.
Note, maven must be installed and configured
- Download Storm http://www.apache.org/dyn/closer.lua/storm/apache-storm-0.10.0/apache-storm-0.10.0.tar.gz
- Install the examples
- from the storm directory
cd examples/storm-starter
mvn clean install -DskipTests=true
- Compile the wordcount example
mvn compile exec:java -Dstorm.topology=storm.starter.WordCountTopology
- Or use
bin/storm jar examples/storm-starter/target/storm-*.jar storm.starter.ExclamationTopology
- Where does the data come from?
- How would you modify this code to make it case-insensitive?