最大值

Javadoc Javadoc


提供各种不同的转换，用于计算集合中的最大值，无论是全局的还是每个键的。

示例

示例 1：获取PCollection of Doubles 的最大值。

PCollection<Double> input = ...;
PCollection<Double> max = input.apply(Max.doublesGlobally());

示例 2：计算与每个唯一键（类型为String）关联的Integers 的最大值。

PCollection<KV<String, Integer>> input = ...;
PCollection<KV<String, Integer>> maxPerKey = input
     .apply(Max.integersPerKey());

示例 3:

示例 4: