Stream
.of(TestData.INPUT_MESSAGES)
.forEach(kv -> in.pipeInput(
Key.of(kv.key.getUser(), kv.key.getWord()),
Entry.of(kv.value.getWord(), kv.value.getCounter())));
Stream
.of(TestData.INPUT_MESSAGES)
.forEach(kv -> in.pipeInput(
Key.of(kv.key.getUser(), kv.key.getWord()),
Entry.of(kv.value.getWord(), kv.value.getCounter())));