0

私は次の列ファミリーを持っています：

CREATE COLUMN FAMILY messages with comparator=DateType and key_validation_class=UTF8Type and default_validation_class=UTF8Type;

現在、CassandraThriftを使用して新しいデータを保存しています。

 TTransport tr = this.dataSource.getConnection();
         TProtocol proto = new TBinaryProtocol(tr);      
         Cassandra.Client client = new Cassandra.Client(proto);
         long timestamp = System.currentTimeMillis();
            client.set_keyspace("myTestSPace");
             ColumnParent parent = new ColumnParent("messages");
             Column messageColumn = new Column();
             String time = String.valueOf(timestamp);        
             messageColumn.setName(time.getBytes());
             messageColumn.setValue(toByteBuffer(msg.getText));
             messageColumn.setTimestamp(timestamp);
             client.insert(toByteBuffer(msg.getAuthor()), parent, messageColumn, ConsistencyLevel.ONE);

しかし、私は例外を得ています：

InvalidRequestException(why:Expected 8 or 0 byte long for date (16))
    at org.apache.cassandra.thrift.Cassandra$insert_result.read(Cassandra.java:15198)
    at org.apache.cassandra.thrift.Cassandra$Client.recv_insert(Cassandra.java:858)
    at org.apache.cassandra.thrift.Cassandra$Client.insert(Cassandra.java:830)
    at com.vanilla.cassandra.DaoService.addMessage(DaoService.java:57)

それを修正する方法は？

4

1 に答える 1

2

生のThriftインターフェースを使用しているようです。遭遇した理由やその他多くの理由から、 Hector、Astyanax、CQLクライアントなどの既存の高レベルクライアントを使用することを強くお勧めします。

問題の根本的な原因は、さまざまなデータ型をバイナリ形式にパックする必要があることです。上位レベルのクライアントはこれを自動的に管理します。

于 2012-11-25T00:16:38.280 に答える