Cassandra 忽略 FetchSize

Question

我有一个 1000 行的 cassandra 表。我正在使用带有 Cassandra 2.1.3 的 datastax java 驱动程序 2.1.8

我已将准备好的选择语句的 fetchSize 设置为 10。 Scala 中的代码：

val stmt = preparedStatement.bind()
stmt.setFetchSize(10)
if(nextPage != null )
  stmt.setPagingState(nextPage)

val rs = session.execute(stmt)
println( rs.all().count ) 
val nextPage = rs.getExecutionInfo().getPagingState()

我在一个循环中运行它，每次都传递 nextPage 值，从一个空值开始。

但是返回的结果忽略了fetchSize，虽然PageState对象是根据fetchSize创建的。每次循环运行的结果计数是... 1000 990 980 ...等等。

我想要的是驱动程序每次返回 10 个结果。我在这里错过了什么？

Answer 1

调用all() 将自动消耗所有剩余页面。有关如何手动获取批量结果的详细信息，请参阅fetchMoreResults 上的 javadoc。