从eachRow()返回nodejs的cassandra驱动程序

Question

在我的节点应用程序中，我使用以下代码来运行一些查询。我想在（arraySize>100）之后调用回调函数并退出。目前，我只能在所有处理完成后退出。

var matchedUsers = [];
client.eachRow(query, [], { prepare : true }, function (n, row) { 
      if(someCondition){
        matchedUsers.push(row.x);
      }
      if(matchedUsers.length>100){
        //exit here
      }
     }, function (err) {
        callback(matchedUsers)
     } );

Answer 1

以下是eachRow:的底层实现

如果我正确阅读了他们的node.js驱动程序，那么整个cassandra结果将根据您提供的查询返回给您。因此，您还可以将所有结果添加到自己的数据结构中，然后对其进行迭代以查找匹配项（当然，当找到匹配项时，就可以跳出循环）。