modifying StreamBenchWordCountTopology