Cassandra 2.0.5、Storm バージョン 0.9.0.1 で Storm の Trident を使用する方法を学んでいます。com.hmsonline storm-cassandra 0.4.0-rc4 contrib も使用しています。
私の目標は、id (int)、名前 (text)、および文 (text) 列を持つテーブルにいくつかのテキスト行を挿入することです。id と name は主キーです。
にはpartitionPersist
が必要でStateUpdater
、そのために を使用していcom.hmsonline.storm.cassandra.trident.CassandraUpdater<K, C, V>
ます。しかし、どうやら、入力として2つではなく1つのキーしか取得できないようです(IDと名前が必要です)。タプル マッパー ( TridentTupleMapper
) も 1 つのキーを使用します。
TridentTupleMapper<K, C, V> tupleMapper
何かが足りないのかもしれませんが、複数の列をキーとして定義するにはどうすればよいですか?