.forEach(kv -> top10In.pipeInput(kv.key, kv.value));
KeyValueStore<String, String> store = testDriver.getKeyValueStore(STORE_NAME);
.forEach(kv -> top10In.pipeInput(kv.key, kv.value));
KeyValueStore<String, String> store = testDriver.getKeyValueStore(STORE_NAME);