SearchIteratorV2()
此操作会创建一个迭代器,供您遍历搜索结果。它尤其适用于搜索结果包含大量数据的情况。
public SearchIteratorV2 searchIteratorV2(SearchIteratorReqV2 request)
请求语法
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
此操作期间发生任何错误时,都会引发此异常。
示例
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);