Googleのデータフロー：Sum.SumIntegerFnは私のEclipseでは見え

Question

ないタイプは、私が「エラーでSum.SumIntegerFnが表示されていないタイプのフラグを立て持っ

import org.apache.beam.sdk.transforms.Sum; 
.... 
something = createAggregator("something", new Sum.SumIntegerFn()); 

Answer 1

私はあなたの「インポートからご覧ください。 Apacheのビームを使用して再。あなたはSum.ofIntegers()の代わりnew Sum.SumIntegerFn()を使用する必要があります。

はまた、Githubの頭で、アグリゲーターが削除されていることに注意してください。代わりに、カウンタメトリックは、同様の動作を提供します。詳細についてはMetricsを参照してください。

Answer 2

Sum.SumIntegerFn()は公開されなくなり、Sum.ofIntegers()に置き換えられました。組み込み関数の代わりに独自のIterable関数を使用するための回避策が必要な場合は、以下のコードブロックを試してみてください。

something = createAggregator("something", new SumIntegers()); 

public static class SumIntegers implements SerializableFunction<Iterable<Integer>, Integer> { 
     @Override 
     public Integer apply(Iterable<Integer> input) { 
      Integer sum = 0; 
      for (Integer item : input) { 
       sum += item; 
      } 
      return sum; 
     } 
    }