Apache Beam - 如何从所有的窗口中通过键对PCollection<KV<String, Int>&gt进行求和。

Question

给定一个 PCollection<KV<String, Int>> 定时窗口的情况下，如何才能将所有的 Int 被 String 钥匙 窗口?

例如

PCollection<KV<String, Int>> pc = ...;  

pc.apply("FixedWindows", Window.<~>into(FixedWindows.of(WindowDuration)) // apply fixed windowing

我怎样才能在 全窗 在这个设置中，每个键都是如此？

我应该使用 Combine.GloballyAsSingletonView<InputT,OutputT> 如果是，我应该如何实现？

Answer 1

Combine总是在你所应用的窗口范围内进行。 如果要对所有元素进行求和，你需要先将窗口返回到GlobalWindows中

Answer 2

其中一个选项，万一你没有太多不同的键，而且结果之和小于 Long.MAX_VALUE，您可以使用 光束指标譬如 Counter，为此。