.map((windowedWord, counter) -> new KeyValue<>(
WindowedWord.of(
ZonedDateTime.ofInstant(windowedWord.window().startTime(), zone),
ZonedDateTime.ofInstant(windowedWord.window().endTime(), zone),
windowedWord.key().getWord()),
WordCounter.of(windowedWord.key().getWord(), counter)))
.map((windowedWord, counter) -> new KeyValue<>(
WindowedWord.of(
ZonedDateTime.ofInstant(windowedWord.window().startTime(), zone),
ZonedDateTime.ofInstant(windowedWord.window().endTime(), zone),
windowedWord.key().getWord()),
WordCounter.of(windowedWord.key().getWord(), counter)))