0

Kafka からタプルを取得し、それらを 1 つのフィールドでグループ化し、グループ化されたタプル全体を HBase に保持するトライデント トポロジを構築したいと考えています。グループ化の理由は、単一のオブジェクトを配置する場合と比較して、複数の配置オブジェクトを使用すると HBase の配置操作が高速になるためです。オブジェクトを 1 つのフィールドでグループ化し、それらすべてのオブジェクトを 1 回の HBase API 呼び出しでPut挿入したいと考えています。Put

次のコードを書きましたが、すべてのタプルを HBase の「Put」タイプのオブジェクトに変換し、それらすべての Put オブジェクトを HBase に保持するコードをどこに記述すればよいかわかりません。

OpaqueTridentKafkaSpout kafkaTridentSpout = new OpaqueTridentKafkaSpout(spoutConfig);
TridentTopology topology = new TridentTopology();
topology.newStream("stream", kafkaTridentSpout)
                             .groupBy(new Fields("pointId"))
                             .toStream();
topology.build();

誰でも私を助けてもらえますか？

4

1 に答える 1

-1

ストームにはボルトとスパウトがあります。スパウトはソースをリッスンし、ボルトは反対側にあり、並行して動作し、データを宛先に移動します。あなたの場合、スパウトはkafkaをリッスンし、ボルトでデータを取得し、ボルトはHbaseに書き込む必要があります

于 2015-09-23T19:59:29.097 に答える