25 lines (15 loc) · 827 Bytes

CountServer

CounterServer(デフォルトはport:23400)にメッセージを送信すると、直近のワードカウントランキングを出力する

Usage

起動方法
mvn compile exec:java -Dstorm.topology=storm.hot.Topology
オプション：
-Dwidth.slide: 集計結果の出力頻度(秒)、デフォルトは60（毎分出力）
-Dwidth.Window: 現在からの集計対象時間(秒)、デフォルトは3600（直近1時間）
tools/Rankings.javaで出力先を設定
メッセージ送信方法
ソケット通信でポート23400にメッセージを投げてください
HotWordSpout.javaでポートとかは設定できます

UserDictionary

resourses/dic.csvはユーザ辞書
SplitBolt.javaあたりを見てもらうと読み込むユーザ辞書の設定が可能