ElasticsearchとKibanaを使ってTwitterのトレンドワードを可視化してみた - FLINTERS Engineer's Blog
大久保です。 最近、会社でElasticsearch＋Kibana＋Fluentdという定番の組み合わせを使ってログ解析する機会があったので、ついでにいろいろ勉強してみました。 触ってみておもしろかったのが、Elasticsearchがログ解析だけじゃなくてちょっとしたKVSのようにも振る舞えることです。 ElasticsearchはKibanaと組み合わせることで、もっといろいろおもしろいことできそう感あります！！ 本記事では、その一例としてTwitterのトレンドワードをリアルタイムに集計するプログラムを組んでみました。 完成形：トレンドワードごとのツイート数をグラフ化 ＃開発環境と各種ミドルウェアのバージョン ローカルで確認できればよかったので開発環境はMacです。 Java ElasticsearchはJava製なのでJavaのバージョンを確認。 $ java -version j
ゴールドマン・サックス発のJavaコレクションフレームワーク、その7つの特徴と歴史とは
ゴールドマン・サックス発のJavaコレクションフレームワーク、その7つの特徴と歴史とは：コレクション処理の万能道具箱Eclipse Collections入門（1）（1/3 ページ） 本連載では、ゴールドマン・サックス発のオープンソースJavaコレクションフレームワークであるEclipse Collectionsについて、その概要と歴史、機能を中心に紹介します。これまでのJavaやJava 8のStream APIと比較して何が違うのか。Eclipse Collectionsを例に、読者の皆さんがコレクション処理をより深く理解するための一助になればと思います。 ゴールドマン・サックスが開発し、オープンソースソフトウェア（OSS）として公開したJavaコレクションフレームワーク「GS Collections」が、Eclipse Foundationに移行し、「Eclipse Collecti
Java 8のStream APIの性能まとめ - Qiita
結果、速度性能が良かったものの順に「○→△→×」を上表に記載しました。 速度性能結果の考察 粒度が小さい処理の場合 中間操作～終端操作の一連の処理のコストが小さい場合は、JITによる最適化が効くまでの間は「Streamを使わない処理」が最も速度性能が優れています。 しかし、サーバなど長期運用ではJITによる最適化により「Streamを利用したのシリアル処理」の速度性能は「Streamを使わない処理」と同程度になります。 なお、「Streamを利用したパラレル処理」の場合、パラレル制御のオーバーヘッドが大半を占めるため、JITによって最適化されても速度性能が優れることは望めません。 粒度が大きい処理の場合 中間操作～終端操作の一連の処理のコストが大きい場合は、「Streamを使用したパラレル処理」を積極的に検討してよい。 ただし、念のためにシリアル処理とパラレル処理の性能比較はしておいた方が
Java 8 Stream API にテキストを流してみた（終端操作編） - Qiita
Java 8 Stream API にテキストを流してみる（生成編）- Qiita Java 8 Stream API にテキストを流してみた（終端操作編）- Qiita Java 8 Stream API にテキストを流してみて（中間操作編）- Qiita 要するにだ Java 8 Stream は実行前も実行後もデータを保持しない。 Streamクラス自体はコレクションではなく、流れてくる個々の要素に対する操作のパイプラインを構成しているだけだ。従って Stream を通して加工された要素をデータとして扱うためには、最終的にまた何らかのデータ構造なり値なりに戻されなければならない。 そのためのメソッド群を「終端操作(Terminal operation）」と呼び、そのほかの「中間操作(Intermediate operation)」と区別する。 中間操作メソッドは要素に適用する関数をパ
Java8のStreamを使いこなす - きしだのHatena
さて、Java8で関数型っぽいことをやって遊んでみたわけですが、実際はそんな書き方しませんよね。 Java8で実際に使うのは、Streamです。 ということで、Streamの使い方をひととおり見てみます。 ※5/17 仕様変更があったので、修正しました 基本 まずは、Iterableインタフェースに用意されたforEachメソッドを見てみましょう。 List<String> names = Arrays.asList("hoge hoge", "foo bar", "naoki", "kishida"); names.forEach(s -> System.out.println(s)); これで次のように表示されます。 hoge hoge foo bar naoki kishida いままでの拡張forだと次のように書いてました List<String> names = Arrays.a
[Java8] はじめて触るStreamの世界 | DevelopersIO
札幌は大荒れ、の予想だったのですが、今のところ大変穏やかな天候です。こんにちは。こむろです。 この記事はJava Advent Calendar 2014の17日目になります。 昨日16日は@zephiransasさんの「Lambda-behaveでテストを書こう」でした。 Java8の素晴らしき世界 Java8を使ってプログラミングしていると、新しい機能を色々と使うことで簡潔で読みやすいコードを記述することが出来ます。これが思いの外楽しくるんるん気分でコードを書くことが出来ます。今までのように型をいちいち書かなきゃとかネスト地獄みたいなところを、少しだけ、でも大胆に改善することが出来、久々にJavaでコードを書いていて楽しいと思った時間でした。AndroidはJavaではｎ（ｒｙ 特にここ数ヶ月、Play for JavaでJava8を利用した開発をしていたのですが、その中でStream
![[Java8] はじめて触るStreamの世界 | DevelopersIO](https://cdn-ak-scissors.b.st-hatena.com/image/square/30a2d47409e2c1d5a3c01b1ecbba01690af9a821/height=288;version=1;width=512/https%3A%2F%2Fdevio2023-media.developers.io%2Fwp-content%2Fuploads%2F2013%2F09%2Fjava.png)
蒐集してやんよ java.util.stream.Collectors クラス (4) - parallel ストリーム と concurrent コレクタ - - 倭マン's BLOG
Java の Collectors クラスに定義されているメソッドを見ていくシリーズ（目次）。 Stream や Collector に関する記事をそこそこ書いてきて今さらいうのもアレですが、parallel ストリームと concurrent コレクタに関してちょっと（というか根本的に？）勘違いしてた気がするので、ちょっとここいらに関する記事を書いておくことに。 java.util.stream.Collectors クラスの static メソッドから取得できるコレクタのなかで特性 (characteristics) が CONCURRENT なのは toConcurrentMap() と groupingByConcurrent() の2つでした（→）。 これらのメソッドで返されるコレクタは CONCURRENT 特性を持ちますが、これらのコレクタを単に使うだけで並行処理をしてくれる
Java8 逆引き Stream API - Qiita
はじめに Java8の新機能、Stream APIを使い始めてコーディングが格段に楽になりました。 備忘録的にサンプルコードを書き出してみました。少しずつ追加していく予定です。 Javaは使ったことあるけどラムダ式やStream APIはよく知らないという方は、参考にしてみてください。 バリバリ使っている方は、こんな使い方もあるよ！と教えていただけると嬉しいです。 ちなみにオライリー社のJavaによる関数型プログラミング ―Java 8ラムダ式とStreamがとても参考になりました。 【前提条件】Stream APIの説明に使用するオブジェクト public class Person { private String name; private int age; private List<Person> children; public Person(String name){/*...*
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
