最大值

Javadoc Javadoc


提供各種不同的轉換,用於計算集合中的最大值,無論是全域還是每個鍵的最大值。

範例

範例 1:取得 DoublesPCollection 的最大值。

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: