queryIterator()

queryIterator()

此方法返回一个查询迭代器，用于迭代数据。

java

public QueryIterator queryIterator(QueryIteratorReq request)

请求语法

java

queryIterator(QueryIteratorReq.builder()
    .databaseName(String databaseName)
    .collectionName(String collectionName)
    .clusterId(String clusterId)
    .partitionNames(List<String> partitionNames)
    .outputFields(List<String> outputFields)
    .expr(String expr)
    .consistencyLevel(ConsistencyLevel consistencyLevel)
    .offset(long offset)
    .limit(long limit)
    .ignoreGrowing(boolean ignoreGrowing)
    .timezone(String timezone)
    .batchSize(long batchSize)
    .reduceStopForBest(boolean reduceStopForBest)
    .filterTemplateValues(Map<String, Object> filterTemplateValues)
    .build()
);

构建器方法：

• databaseName(String databaseName)

  Database 的名称。若未指定，则默认为当前 Database。

• collectionName(String collectionName)

  目标 Collection 的名称。

• clusterId(String clusterId)

  此向量读取请求的目标集群 ID。当多个请求需要共享同一个集群 ID 时，请使用 session(String clusterId)。

• partitionNames(List<String> partitionNames)

  要查询的 Partition 名称列表。

• outputFields(List<String> outputFields)

  要包含在输出中的字段名称列表。

• expr(String expr)

  用于筛选结果的布尔表达式。

• consistencyLevel(ConsistencyLevel consistencyLevel)

  此操作的一致性级别。

• offset(long offset)

  返回结果前要跳过的结果数量。

• limit(long limit)

  要返回的最大结果数量。

• ignoreGrowing(boolean ignoreGrowing)

  是否在操作期间忽略增长中的 Segment。

• timezone(String timezone)

  用于时间相关筛选的时区字符串。

• batchSize(long batchSize)

  迭代器操作的批处理大小。

• reduceStopForBest(boolean reduceStopForBest)

  找到最佳结果时是否停止迭代。

• filterTemplateValues(Map<String, Object> filterTemplateValues)

  参数化筛选器的模板变量值映射。

返回值：

QueryIterator

QueryIterator

异常：

• MilvusClientException

  当此操作期间发生任何错误时，将引发此异常。

示例

java

import io.milvus.orm.iterator.QueryIterator;
import io.milvus.response.QueryResultsWrapper;
import io.milvus.v2.service.vector.request.QueryIteratorReq;
import io.milvus.v2.common.ConsistencyLevel;

import java.util.Arrays;
import java.util.List;

// Create a query iterator to retrieve results in batches
QueryIterator queryIterator = client.queryIterator(QueryIteratorReq.builder()
        .collectionName("my_collection")
        .expr("userID < 3000")
        .outputFields(Arrays.asList("userID", "userAge"))
        .batchSize(100)
        .offset(0)
        .limit(10000)
        .consistencyLevel(ConsistencyLevel.BOUNDED)
        .build());

// Iterate through all results
int counter = 0;
while (true) {
    List<QueryResultsWrapper.RowRecord> res = queryIterator.next();
    if (res.isEmpty()) {
        queryIterator.close();
        break;
    }
    for (QueryResultsWrapper.RowRecord record : res) {
        System.out.println(record);
        counter++;
    }
}
System.out.printf("%d query results returned%n", counter);