跳到主要内容

SearchIteratorV2()

此操作会创建一个迭代器,供您遍历搜索结果。它尤其适用于搜索结果包含大量数据的情况。

java
public SearchIteratorV2 searchIteratorV2(SearchIteratorReqV2 request)

请求语法​

java
searchIteratorV2(SearchIteratorReqV2.builder()
.databaseName(String databaseName)
.collectionName(String collectionName)
.clusterId(String clusterId)
.partitionNames(List<String> partitionNames)
.vectorFieldName(String vectorFieldName)
.topK(int topK)
.limit(long limit)
.filter(String filter)
.outputFields(List<String> outputFields)
.vectors(List<BaseVector> vectors)
.roundDecimal(int roundDecimal)
.searchParams(Map<String, Object> searchParams)
.consistencyLevel(ConsistencyLevel consistencyLevel)
.ignoreGrowing(boolean ignoreGrowing)
.timezone(String timezone)
.groupByFieldName(String groupByFieldName)
.batchSize(long batchSize)
.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 名称列表。

  • vectorFieldName(String vectorFieldName)

    要搜索的向量字段名称。

  • topK(int topK)

    要返回的前几条结果数量。

  • limit(long limit)

    要返回的最大结果数量。

  • filter(String filter)

    用于过滤结果的布尔表达式。

  • outputFields(List<String> outputFields)

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

  • vectors(List<BaseVector> vectors)

    用于搜索的向量列表。

  • roundDecimal(int roundDecimal)

    距离值四舍五入时保留的小数位数/score。

  • searchParams(Map<String, Object> searchParams)

    以键值对形式提供的附加搜索参数。

  • consistencyLevel(ConsistencyLevel consistencyLevel)

    此操作的一致性级别。

  • ignoreGrowing(boolean ignoreGrowing)

    是否在操作期间忽略 growing Segment。

  • timezone(String timezone)

    用于时间相关过滤器的时区字符串。

  • groupByFieldName(String groupByFieldName)

    用于对搜索结果进行分组的字段名称。

  • batchSize(long batchSize)

    迭代器操作的批次大小。

  • filterTemplateValues(Map<String, Object> filterTemplateValues)

    参数化过滤器的模板变量值映射。

返回:

SearchIteratorV2

SearchIteratorV2

异常:

  • MilvusClientException

    此操作期间发生任何错误时,都会引发此异常。

示例​

java
import io.milvus.orm.iterator.SearchIteratorV2;
import io.milvus.v2.service.vector.request.SearchIteratorReqV2;
import io.milvus.v2.service.vector.request.data.FloatVec;
import io.milvus.v2.service.vector.response.SearchResp;
import io.milvus.v2.common.ConsistencyLevel;
import io.milvus.v2.common.IndexParam;

import java.util.Arrays;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;

// Create a SearchIteratorV2 for paginated vector search.
// V2 is recommended over V1: 20-30% faster with better recall.
SearchIteratorV2 searchIterator = client.searchIteratorV2(SearchIteratorReqV2.builder()
.collectionName("my_collection")
.outputFields(Arrays.asList("userAge"))
.batchSize(50)
.vectorFieldName("userFace")
.vectors(Collections.singletonList(new FloatVec(queryVector)))
.filter("userAge > 10 && userAge < 20")
.searchParams(new HashMap<>())
.limit(120)
.metricType(IndexParam.MetricType.L2)
.consistencyLevel(ConsistencyLevel.BOUNDED)
.build());

// Iterate through search results
int counter = 0;
while (true) {
List<SearchResp.SearchResult> res = searchIterator.next();
if (res.isEmpty()) {
searchIterator.close();
break;
}
for (SearchResp.SearchResult result : res) {
System.out.println(result);
counter++;
}
}
System.out.printf("%d search results returned%n", counter);
最低 SDK 版本v3.0.x