使用 Hector 查询 Cassandra 中的 CompositeType 列

java cassandra hector composite-types

2022-09-04 21:28:34

以下是我面临的方案示例。假设我有这个专栏系列：

    create column family CompositeTypeCF 
    with comparator = 'CompositeType(IntegerType,UTF8Type)' 
    and key_validation_class = 'UTF8Type' 
    and default_validation_class = 'UTF8Type'

以下是一些使用Hector的Java代码示例，说明如何将一些数据插入到此列系列中：

 Cluster cluster = HFactory.getOrCreateCluster("Test Cluster", "192.168.1.6:9160");
 Keyspace keyspaceOperator = HFactory.createKeyspace("CompositeTesting", cluster);
 Composite colKey1 = new Composite();
 colKey1.addComponent(1, IntegerSerializer.get());
 colKey1.addComponent("test1", StringSerializer.get());
 Mutator<String> mutator = HFactory.createMutator(keyspaceOperator, StringSerializer.get());
 Mutator<String> addInsertion = mutator.addInsertion("rowkey1", "CompositeTypeCF",
     HFactory.createColumn(colKey1, "Some Data", new CompositeSerializer(), StringSerializer.get()));
 mutator.execute();

这有效，如果我去cassandra-cli并做一个列表，我得到这个：

$ list CompositeTypeCF;

Using default limit of 100
-------------------
RowKey: rowkey1
=> (column=1:test1, value=Some Data, timestamp=1326916937547000)

我现在的问题是：如何在赫克托耳中查询这些数据？基本上，我需要通过几种方式查询它：

给我整行，其中行键 = “rowkey1”
给我列数据，其中列名的第一部分= 某个整数值
给我列名的第一部分在特定范围内的所有列

答案 1

良好的起点教程在这里。

但是，在终于需要使用复合组件并尝试针对数据编写查询之后，我想出了一些我想分享的东西。

搜索复合列时，结果将是一个连续的列块。

因此，假设 s 复合 3 个字符串，我的列如下所示：

A:A:A
A:B:B
A:B:C
A:C:B
B:A:A
B:B:A
B:B:B
C:A:B

对于从 A：A：A 到 B：B：B 的搜索，结果将为

A:A:A
A:B:B
A:B:C
A:C:B
B:A:A
B:B:A
B:B:B

注意到“C”组件了吗？开始/结束条款中没有“C”组件！什么原因？这些是 A：A：A 和 B：B：B 列之间的所有结果。复合搜索词不会像处理嵌套循环一样给出结果（这是我最初的想法），而是，由于列是排序的，因此您正在为连续的列块指定开始和结束项。

构建复合搜索条目时，必须指定组件相等

只有最后一个学期应该GREATER_THAN_EQUAL，所有其他学期都应该是平等的。例如：对于上述内容

Composite start = new Composite();
start.addComponent(0, "A", Composite.ComponentEquality.EQUAL);
start.addComponent(1, "A", Composite.ComponentEquality.EQUAL);
start.addComponent(2, "A", Composite.ComponentEquality.EQUAL);

Composite end = new Composite();
end.addComponent(0, "B", Composite.ComponentEquality.EQUAL);
end.addComponent(1, "B", Composite.ComponentEquality.EQUAL);
end.addComponent(2, "B", Composite.ComponentEquality.GREATER_THAN_EQUAL);

SliceQuery<String, Composite, String> sliceQuery = HFactory.createSliceQuery(keyspace, se, ce, se);
sliceQuery.setColumnFamily("CF").setKey(myKey);
ColumnSliceIterator<String, Composite, String> csIterator = new ColumnSliceIterator<String, Composite, String>(sliceQuery, start, end, false);

while (csIterator.hasNext()) ....

答案 2