1

我有一个简单的列族：

CREATE TABLE activesubs(
sub_id BIGINT, 
sub_data BLOB, 
user_id BIGINT,
user_data BLOB,
updated BIGINT,
PRIMARY KEY (user_id, sub_id)
) WITH compaction = { 'class' : 'LeveledCompactionStrategy' };

当我使用 cqlsh 查询所有行时，我得到了预期的结果集：

SELECT user_id from activesubs;
user_id
---------
2512
.....
4396

(83 rows)

cqlsh:game>

但是，当我使用 java API 尝试此操作时，我得到 0 结果，代码非常简单：

Iterable<Row> results = session.execute("select user_id from activesubs") ;

我玩过，如果我更改架构以便只有 sub_id 是主键，那么查询通过 java api 工作......

我正在使用最新的 api 版本：

    <dependency>
        <groupId>com.datastax.cassandra</groupId>
        <artifactId>cassandra-driver-core</artifactId>
        <version>2.0.0-rc2</version>
  </dependency>

有人见过这个吗？我做错了什么还是api的错误？

4

0 回答 0