使用Cassandra和CQL3，如何在单个请求中插入整个宽行？

Question

我想在Cassandra 1.2.8中插入一个有50,000列的单行。在插入之前，我已经准备好了整行的所有数据（在内存中）：

+---------+------+------+------+------+-------+
|         | 0    | 1    | 2    | ...  | 49999 |
| row_id  +------+------+------+------+-------+
|         | text | text | text | ...  | text  |
+---------+------+------+------|------+-------+

列名是整数，允许对分页进行切片。列值是该特定索引处的值。

create table results (
    row_id text,
    index int,
    value text,
    primary key (row_id, index)
) 
with compact storage;

INSERT INTO results (row_id, index, value) values (my_row_id, ?, ?);

这要花很多时间。即使当我们把上面的插入物放入一批中时，也需要大量的时间。

我们已经有了所需的全部数据（完整的行），我假设只说“这里，Cassandra，在一个请求中将此数据存储为单行”是非常容易的，例如：

//EXAMPLE-BUT-INVALID CQL3 SYNTAX:
insert into results (row_id, (index,value)) values 
    ((0,text0), (1,text1), (2,text2), ..., (N,textN));

通过当前的CQL3语法，这个示例是不可能的，但我希望它说明了预期的效果：所有内容都将作为一个查询插入。

在CQL3和DataStax Java驱动程序中可以做到这一点吗？如果没有，我想我将被迫使用Hector或Astyanax驱动程序和节俭batch_insert操作？

Answer 1

通过使用变异多映射，可以在节俭API中使用batch_mutate方法进行多次插入/更新。

Map<byte[], Map<String, List<Mutation>>> mutationMap = new HashMap<byte[], Map<String, List<Mutation>>>();

List<Mutation> mutationList = new ArrayList<Mutation>();

mutationList.add(mutation);
Map<String, List<Mutation>> m = new HashMap<String, List<Mutation>>();

m.put(columnFamily, mutationList);

mutationMap.put(key, m);
client.batch_mutate(mutationMap, ConsistencyLevel.ALL);