スパウトを介して 1 つのデータベースからデータを取得し、そのデータを処理して、trident を使用して別のデータベースに保存したいと考えています。スパウト (トライデントでサポートされている IRichSpout を実装する別の Java クラス) をオブジェクトとして出力します。それをトライデント トポロジに渡して処理 (レコード数のカウント) し、データベースに保存する必要があります。
TridentTopology topology = new TridentTopology();
TridentState wordCounts =
topology.newStream("spout1",spout)
新しいストリームはスパウトを入力として受け取ります。つまり、構文は次のとおりです。
Stream storm.trident.TridentTopology.newStream(String txId, IRichSpout spout)
しかし、スパウトによって放出されたオブジェクトを、トライデントが処理してデータベースに保存するためのストリームへの入力として提供したいので、どのようにスパウト クラスをトライデント内に持ってきて、それを新しいストリームに渡すことができますか、スパウトとスパウトの両方を組み合わせる必要がありますか?トライデントと同じクラス??
誰か助けてくれませんか.....