fits https://blog.hatena.ne.jp/fits/ なんとなくな Developer のメモ https://fits.hatenablog.com/ Java 前回 と同様の処理を Java8 のラムダ式を使って実装してみました。 Apache Flink 1.2.0 今回のソースは http://github.com/fits/try_samples/tree/master/blog/20170313/ サンプル 前回 の処理をラムダ式を使って Java で実装すると以下のようになりました。 MoneyCount.java import org.apache.flink.api.java.ExecutionEnvironment; import org.apache.flink.api.java.tuple.Tuple2; public class… 190 <iframe src="https://hatenablog-parts.com/embed?url=https%3A%2F%2Ffits.hatenablog.com%2Fentry%2F2017%2F03%2F13%2F211354" title=" Java 8 で Apache Flink を使用 - なんとなくな Developer のメモ" class="embed-card embed-blogcard" scrolling="no" frameborder="0" style="display: block; width: 100%; height: 190px; max-width: 500px; margin: 10px 0px;"></iframe> Hatena Blog https://hatena.blog 2017-03-13 21:13:54 rich https://fits.hatenablog.com/entry/2017/03/13/211354 1.0 100%