... .apply(GroupByKey.<String, Integer>create()) .apply( ParDo.named("MySum") .of( new DoFn<KV<String, Iterable<Integer>>, KV<String, Integer>>() { @Override public void processElement(ProcessContext c) { String key = c.element().getKey(); int summedValue = 0; for (int i : c.element().getValue()) { summedValue += i; } c.output(KV.of(key, summedValue)); } })) ...
... .apply(GroupByKey.<String, Integer>create()) .apply("MySum", Combine.<String,Integer>groupedValues( new SerializableFunction<Iterable<Integer>, Integer>() { @Override public Integer apply(Iterable<Integer> values) { int summedValue = 0; for (int i : values) { summedValue += i; } return summedValue; } })) ...
.apply(GroupByKey.<String, Integer>create()) .apply("MySum", Combine.<String,Integer>groupedValues( new SerializableFunction<Iterable<Integer>, Integer>() { @Override public Integer apply(Iterable<Integer> values) { int summedValue = 0; for (int i : values) { summedValue += i; } return summedValue; } })) ...
「Docker は、幅広いシステムで動作するようにソフトウェアをパッケージ化することで、ソフトウェアのビルド、リリース、実行を容易にする」
「しかし、それだけでは不十分だ。われわれは、そうしたソフトウェアがインストールされ、機能し、高い可用性を発揮するための方法も必要としている。Kubernetes のようなものが必要なのだ」
