Я хочу получить количество элементов, присутствующих в функции суммы. Пример:
val counts = text.flatMap { _.toLowerCase.split("\\W+") }
.map { (_, 1) }
.keyBy(0)
.timeWindow(Time.minutes(10))
.sum(1)
выход:
hello : 4
world : 2
foo : 8
my : 5
Я хочу, чтобы на выходе число 4
соответствовало количеству элементов. Я не нахожу никакой функции, подобной count