-
Notifications
You must be signed in to change notification settings - Fork 2
Getting Started
Sample topologies are provided in the examples folder. In particular:
- BasicExclamationTopology.java: a variant of the classic WordCount exclamation topology where QT injects automatically tuples parsed from test.json. In the release this is a file integrated in the QT jar file. The change this file, change the JSON file name in the Maven pom.xml file
- ExclamationTopology.java: This is a variant of the BasicExclamationTopology that cyclically increases the QT load until matching a predefined criterion, such as reaching a target bolt capacity as seen from the StormUI or the DICE Monitoring Platform (DMON).
Run
mvn package
to build the target topology. This can be submitted to a Storm testbed as usual. The Maven pom.xml file is configured to build by default ExclamationTopology, change
com.github.dice-project.qt.examples.ExclamationTopology
inside pom.xml to
com.github.dice-project.qt.examples.BasicExclamationTopology
to build BasicExclamationTopology.
An example is provided in both source code and binary distributions.
In the source code distribution, after adding the qt-gen folders to the path, run:
qt_gen_main
The example reads wc2014-100.json and generates the new trace wc2014-generated.json. The number of messages included in the new trace can be defined through the nMessages parameter in qt_config.xml.