タグ

関連タグで絞り込む (1)

タグの絞り込みを解除

stormとtridentに関するkimutanskのブックマーク (2)

  • Notes on Storm+Trident tuning

    You signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session. You switched accounts on another tab or window. Reload to refresh your session. Dismiss alert

    Notes on Storm+Trident tuning
    kimutansk
    kimutansk 2015/09/05
    JVMサイズ2.5GB、短命オブジェクトが多いことが前提、interval.millisでバッチ起動の間隔制御、max-pendingで並列実行数制御とpreferIPv4あたりが重要ですか。
  • Tridentの並列数の指定方法 - しろかい!

    Tridentの並列数の指定方法についてまとめました. Tridentでは,ストリームを定義する時にparallelismHint()メソッドを書くことで,直前のOperationの並列数の指定が可能. ただし,単に記述しただけではダメみたいです. 例えば,以下の様なストリームを定義します. Stream inputStream = topology .newStream("sentence", spout) .each(new Fields("field"), new Function1()) .each(new Fields("field"), new Function2(), new Fields()) .parallelismHint(10); これを実行すると,Function2()が10並列になるかと思いきや,されません. しかし,以下のようにFunction1()とFunct

    Tridentの並列数の指定方法 - しろかい!
    kimutansk
    kimutansk 2015/07/01
    StormTridentの並列度のカラクリについて日本語の記事が。英語ページ示すのだとハードル高いのでありがたいですね。通信伴う場合に並列度切り替え可能、は結構説明大変
  • 1