了解 Cassandra 中单个分区的读取

我有一个 3 节点设置，Node1 (172.30.56.60)、Node2 (172.30.56.61) 和 Node3 (172.30.56.62)， 它具有100K的单个分区数据，分区由nodeip构成。
请查找 NodeIP 的令牌/分区值 - 172.30.56.60

cqlsh:qnapstat> SELECT token(nodeip) FROM nodedata WHERE nodeip = '172.30.56.60' LIMIT 5; 

 system.token(nodeip)
----------------------
   222567180698744628
   222567180698744628
   222567180698744628
   222567180698744628
   222567180698744628

根据下面提供的 ./nodetool 环值，“172.30.56.60”只会将数据返回到协调器，因为从 173960939250606057 到 239923324758894350 的值是由节点 172.30.56.60 处理的。注：这是我的理解

172.30.56.60  rack1       Up     Normal  32.72 MiB       100.00%             173960939250606057                          
172.30.56.62  rack1       Up     Normal  32.88 MiB       100.00%             239923324758894351                          
172.30.56.61  rack1       Up     Normal  32.84 MiB       100.00%             253117576269706963                          
172.30.56.60  rack1       Up     Normal  32.72 MiB       100.00%             273249439554531014                          
172.30.56.61  rack1       Up     Normal  32.84 MiB       100.00%             295635292275517104                          
172.30.56.62  rack1       Up     Normal  32.88 MiB       100.00%             301162927966816823                          

我在这里有两个问题，

1）当我尝试执行以下查询时，这是否意味着协调器（例如172.30.56.61）从172.30.56.60读取所有数据？

2）协调器收到所有100K条目后，是否会执行100K的聚合，如果是这样，它会将所有100K条目保留在172.30.56.61的内存中吗？

SELECT Max(readiops) FROM nodedata WHERE nodeip = '172.30.56.60';

有一个不错的工具叫做CQL追踪这可以帮助您理解并查看执行 SELECT 查询后的事件流程。

cqlsh> INSERT INTO test.nodedata (nodeip, readiops) VALUES (1, 10);
cqlsh> INSERT INTO test.nodedata (nodeip, readiops) VALUES (1, 20);
cqlsh> INSERT INTO test.nodedata (nodeip, readiops) VALUES (1, 30);
cqlsh> select * from test.nodedata ;

 nodeip | readiops   
--------+-----------
      1 |        10 
      1 |        20 
      1 |        30 

(3 rows)
cqlsh> SELECT MAX(readiops) FROM test.nodedata WHERE nodeip = 1;

 system.max(readiops)
-----------------------
                   30

(1 rows)

现在让我们设置cqlsh> TRACING ON并再次运行相同的查询。

cqlsh> TRACING ON
Now Tracing is enabled
cqlsh> SELECT MAX(readiops) FROM test.nodedata WHERE nodeip = 1;

 system.max(readiops)
----------------------
                   30

(1 rows)

Tracing session: 4d7bf970-eada-11e7-a79d-000000000003


 activity                                                                                                                                                        | timestamp                  | source       | source_elapsed
-----------------------------------------------------------------------------------------------------------------------------------------------------------------+----------------------------+--------------+----------------
                                                                                                                                              Execute CQL3 query | 2017-12-27 07:48:44.404000 | 172.16.0.128 |              0
                                                                                                        read_data: message received from /172.16.0.128 [shard 4] | 2017-12-27 07:48:44.385109 |  172.16.0.48 |              9
                                                                                       read_data handling is done, sending a response to /172.16.0.128 [shard 4] | 2017-12-27 07:48:44.385322 |  172.16.0.48 |            222
                                                                                                                                   Parsing a statement [shard 1] | 2017-12-27 07:48:44.404821 | 172.16.0.128 |             --
                                                                                                                                Processing a statement [shard 1] | 2017-12-27 07:48:44.404913 | 172.16.0.128 |             93
 Creating read executor for token 6292367497774912474 with all: {172.16.0.128, 172.16.0.48, 172.16.0.115} targets: {172.16.0.48} repair decision: NONE [shard 1] | 2017-12-27 07:48:44.404966 | 172.16.0.128 |            146
                                                                                                          read_data: sending a message to /172.16.0.48 [shard 1] | 2017-12-27 07:48:44.404972 | 172.16.0.128 |            152
                                                                                                             read_data: got response from /172.16.0.48 [shard 1] | 2017-12-27 07:48:44.405497 | 172.16.0.128 |            676
                                                                                                                  Done processing - preparing a result [shard 1] | 2017-12-27 07:48:44.405535 | 172.16.0.128 |            715
                                                                                                                                                Request complete | 2017-12-27 07:48:44.404722 | 172.16.0.128 |            722

至于你的问题：

1. 协调器将查询传递给副本，如果RF = 1 or (RF > 1 and CL=ONE)，那么它将收到来自 1 个副本的回复，但是如果 (RF > 1 and CL > 1），而不是需要接收来自多个副本的回复并比较答案，因此协调器端也完成了编排。 它实际完成的方式是向最快的副本发出数据请求（使用告密者），并向满足 CL 所需的其他副本发出摘要请求。 然后协调器需要对数据响应进行哈希处理并摘要请求并进行比较。 如果分区被散列到特定节点，它将驻留在该节点中（假设 RF=1），并且只能从该节点读取信息。

2. 客户端随查询一起发送页面大小，因此回复本身会批量返回（默认=5000），可以从客户端设置。

我推荐看这个剪辑 Cassandra 阅读路径以获取更多详细信息。