私はストームで 1 つのことに苦労しています。したがって、全体のアイデアは次のとおりです。
- ストーム (おそらく DRPC サーバー) に要求を送信します。リクエストは、ストームにストリームのソースを伝えます。例: 2 つのファイル
1 - '/var/log/syslog'と2- ' /var/log/udev' . 「ストーム」にリクエストを送信して、どのファイルを処理するかを伝えたいです。
わからないこと:
「ストーム」にリクエストを送ると言いましたが、どこに送ればいいですか？(私は、DRPC サーバーがどのソースをトポロジーに送信する必要があるかを制御していると仮定します。しかし、DRPC サーバーを実装する方法はDRPCServer server = new DRPCServer()?では、指定されたソースを使用して開始するにはどうすればよいですか?メソッドSpoutにリクエストを送信する必要があるということですか?open()