Skip to content

Latest commit

 

History

History
47 lines (38 loc) · 767 Bytes

README.md

File metadata and controls

47 lines (38 loc) · 767 Bytes

Word Count Example

Inside the dev container

Access the project directory

cd /demo/WordCount

Compile

mvn clean compile assembly:single

Run the WordCount topology in a remote cluster

storm jar \
  target/WordCount-1.0-SNAPSHOT-jar-with-dependencies.jar \
  io.github.carloshkayser.wordcount.topologies.Topology remote

Check the topology status

storm list

Monitor the topology

# TODO

Kill the topology

storm kill wordCountTopology

Execute the topology locally

storm local \
  target/WordCount-1.0-SNAPSHOT-jar-with-dependencies.jar \
  io.github.carloshkayser.wordcount.topologies.Topology local

Check the results in the wordcount.txt file.

cat wordcount.txt