看看吧 scan 组合子。它会给你聚合力 fold / reduce 但它会发出中间结果。
scan
fold
reduce
// .reduce((l, r) => (l._1, l._2 + r._2)) .scan("" 锟斤拷 0)((l, r) => (l._1, l._2 + r._2))
此外,如果要将输出发送到日志记录 Sink ,你可以看看 alsoTo ,这将有效地执行广播到一方 Sink 选择。
Sink
alsoTo