私はボルト "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の特定のストリームを聞く方法を知っていますか?