2016-12-20 5 views
0

私はボルト "XBOLT"を持っています。これは、いくつかの条件に基づいて2つのストリーム(INTRESTED & ARCHIVED)を放出します。yamlのapache stormとfluxを使ってボルトで特定のストリームを聞くにはどうすればいいですか

私は2つのボルト "YBOLT"と "ZBOLT"を持っています。どちらもXBOLTを聞いていますが、ストリームは異なります。たとえば、YBOLTはXBOLTのARCHIVEDストリームをリスンし、ZBOLTはXBOLTのINRESTEDストリームをリッスンします。

私は最近、Fluxを使用して暴風雨を開始し、上記を実装しようとしました。

ストリーム:

  • 名: - から "XBOLT> YBOLT" : "XBOLT" へ: "YBOLT" グルーピング: タイプ:SHUFFLE

  • 名「XBOLT - > ZBOLT」 から: "XBOLT" へ: "ZBOLT" グループ: タイプ:SHUFFLE

ここで、セクションをグループ化するには、「ストリーム」のようなフィールドがもう1つ必要ですか?そうでない場合は、XBOLTの特定のストリームを聞く方法を知っていますか?

答えて

0

はい、別のフィールドを使用してストリームの名前を指定できます。 ストリーム定義のグループ化セクション内で 'streamId'プロパティを使用できます。

あなたのケースでは、たとえば次のようなストリームを定義することができます。参考のため

​​

は、あなたがこのドキュメントのストリームとストリームのグループ化セクションを確認することができます。ドキュメントには、バージョン2のスナップショット用ですが、それは私の嵐と0.10.0

http://storm.apache.org/releases/2.0.0-SNAPSHOT/flux.html

のフラックスバージョンで正常に動作しています
関連する問題