SOL is a throughput test. It will create multiple layers, and then do random shuffling between these layers.

SOLProducer -> SOLProcessor -> SOLProcessor -> ...

The original code comes from: https://github.com/yahoo/storm-perf-test

Supported configurations

    "streamProducer"-> CLIOption[Int]("<stream producer number>", required = false, defaultValue = Some(2)),
    "streamProcessor"-> CLIOption[Int]("<stream processor number>", required = false, defaultValue = Some(2)),
    "bytesPerMessage" -> CLIOption[Int]("<size of each message>", required = false, defaultValue = Some(100)),
    "stages"-> CLIOption[Int]("<how many stages to run>", required = false, defaultValue = Some(2)))

Example:

bin/gear app -jar examples/gearpump-examples-assembly-$VERSION.jar org.apache.gearpump.streaming.examples.sol.SOL