Kafka StreamsをSpring Bootで（その2 - Mitsuyuki.Shiiba
これの続き。ちょーっとずつ進んでるのかなぁ。 bufferings.hatenablog.com こうなった githubにpushしといた https://github.com/bufferings/kafka-streams-demo/tree/v0.1 日本語のsampleストリーム 今度は日本語のsampleストリームを取ってくるようにしてみた。 @Override public void run(String... args) throws Exception { TwitterStream twitterStream = new TwitterStreamFactory().getInstance(); twitterStream.addListener(new StatusAdapter() { @Override public void onStatus(Status st
JJUG ナイトセミナー 「Reactive Streams特集」に行ってきました #jjug
http://www.zhaojunlucky.com/architecture/what-is-reactive-systems/より引用 はじめに JJUG ナイトセミナー 「Reactive Streams特集」に参加してきました。 本記事では実際に参加して感じたこと、学んだことをメモがてらまとめようと思います。 今回参加の目的としては ・自分の中でバズワード化している「リアクティブ」な用語が分からない ・概念はどんなものか？ ・ただのObserverパターンじゃないの？ ・ただのFuture/Promiseじゃないの？ ・ただのデータバインディングじゃないの？ ・Stream APIっぽい関数型パラダイム的な何かじゃないの？ というところの曖昧さの整理とか勉強のためでした。 すでに色んな方がレポートを書いてます。みんな仕事が早いですね(^^; ・JJUGのReactive Stre
Java8 Stream でお手軽に並列処理しよう | TECHSCORE BLOG | TECHSCORE BLOG
Stream#parallel() は要スレッドセーフ Stream#parallel() で並列化されたストリームはマルチスレッドで処理されるため、map や filter などの中間操作、forEach などの終端操作がスレッドセーフではない場合に問題が発生します。 public static void main(String[] a) throws Exception { Set<String> set1 = new ConcurrentSkipListSet<>(); digestStream().parallel().map(String::new).forEach(set1::add); } // 1～10000までの数字文字列のSHA-1ハッシュ値のStreamを返す。 public static Stream<byte[]> digestStream() throws No
JavaのStreamで学ぶ遅延処理実装パターン
6. Streamの復習 repo.findAllUsers().stream() .filter(User::isMen) .filter(u -> u.getAge() >= 27) .filter(u -> u.getAge() <= 35) .map(User::getHobbies) .flatMap(List::stream) .collect(groupingBy( Hobby::getGenre, counting())); ソース ストリームパイプライン 終端操作 7. Streamの疑問 repo.findAllUsers().stream() .filter(User::isMen) .filter(u -> u.getAge() >= 27) .filter(u -> u.getAge() <= 35) .map(User::getHobbies) .flatMap
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
処理を実行中です
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
GitHub - making/spring-cloud-stream-tutorial: Spring Cloud Stream Tutorial
https://cero-t.hatenadiary.jp/entry/20151212/1449929908
