apache-storm

0熱

1答えて

ネット上のさまざまな情報源から、私はStormに（Samoa経由で）いくつかの機械学習機能があることを理解していますが、は常にオンライン学習のためにですか？必然的な質問：このような処理の本質的な反復性のために、ストームはより古典的なバッチ学習には適していないと私は間違っていますか？ありがとうございます。

1熱

1答えて

嵐の噴出口でBlockingQueueを共有

私は、同時に実行されている2つのスレッドがある大きなデータアプリケーションをプログラミングしています。スレッドAはネットワークからデータを受け取り、JSONOBJECTとしてBlockingQueueに配置します。スレッドB、嵐吐き出し、BlockingQueueから読み取り、それらを処理します。私はBlockingQueueオブジェクトをクラスコンストラクタのspoutクラスに渡します。私が見

0熱

1答えて

ストームボルトの待ち時間

トポロジ内の各ボルトの待ち時間を測定しようとしています。パーセンタイルを計算したいので、Stormによって与えられたレイテンシ数は十分ではありません。私の現在の設定では、emitの呼び出しを含むexecuteメソッドを完了するのにかかる時間を測定することによって、ボルトの待ち時間を測定します。上記の方法では、トポロジ内の現在のボルトインスタンスと次のボルトインスタンスの間で同じエグゼキュータが共有

0熱

2答えて

sl4jのバージョンは、Storm 1.0.1とelasticsearch 5.2

でgradleに矛盾しています。私たちは、storm 1.0.1とelasticsearch 5.2でgradleのsl4jバージョンの競合に直面しています。 ElasticSearchはlog4j-to-slf4jブリッジが必要なので、希望のロガーを使用できることがわかりました。ここでは、logback-classicをslf4jで使用しようとしています。依存関係は以下のように定義されていま

0熱

1答えて

サーバー内のストームトポロジとHBaseの接続

HBaseはサーバーのドッカーに格納されています。私はHBaseBoltが含まれているストーム・トポロジーを作成していると私はコードの下としてHBaseBoltを接続： TopologyBuilder builder = new TopologyBuilder(); ... builder.setBolt("indexer", new HBaseBolt("webpage",

0熱

1答えて

Apache Storm＆Vagrant org.apache.storm.utils.NimbusLeaderNotFoundException

私はApache StormとVagrantを初めて使い、Vagrantを使用して構築された仮想化されたクラスタにトポロジを展開したいと考えています。しかし、私は常に嵐のUIからorg.apache.storm.utils.NimbusLeaderNotFoundExceptionを取得しています： org.apache.storm.utils.NimbusLeaderNotFoundExcept

1熱

1答えて

ストームトポロジー：2つのボルトが同じソースボルトを持っているときに正しい方法

私はStormにはかなり新しく、BaseBasicBoltではなくIRichBolt から継承するように最近ボルトを変更しました。私自身の論理に従ったタプル。 My topology looks like this: ボルトAはボルトBとCに同じタプルを出力し、それぞれがカサンドラにデータを保持します。これらの操作は冪等ではなく、2つの異なるカウンタ列ファミリへの更新を含みます。私はタプルに失

0熱

2答えて

複雑なイベントプロセッサーとしてApache stormを使用する方法

CEPとしてapache stormを使用する方法をしばらく探していましたが、CEPでは2つの概念（ストリーム処理と複雑なイベント処理） ESPERのようなデータストリームで実行されますが、私はApacheの嵐でこれと似たものを見つけることができません。これは平均的なApacheの嵐はデータストリームプロセッサーではなくCEPですか？

1熱

1答えて

カフカ・スパウト・インテグレーション

私はカフカ0.10.1.1とストーム1.0.2を使用しています。 kafkaインテグレーションの嵐の文書では、私たちがzookeeperサーバーを使ってkafka spoutを初期化しているので、オフセットはまだzookeeperを使って維持されていることがわかります。 kafkaサーバーを使ってスパウトをブートストラップする方法はありますか？飼育係を使用した嵐のドキュメント BrokerHost

0熱

1答えて

REST APIによるストームトポロジの導入

RESTエンドポイント経由でStormトポロジを導入する方法はありますか？ Storm RESTエンドポイントを見たことがあります。既存のトポロジを有効または無効にすることはできますが、新しいものを追加する場合はどうすればよいですか？何らかの方法があるかもしれません...