org.noear.solon.ai.rag.repository

类 OpenSearchRepository

java.lang.Object

org.noear.solon.ai.rag.repository.OpenSearchRepository

所有已实现的接口:

Repository, RepositoryLifecycle, RepositoryStorable

@Preview(value="3.4")
public class OpenSearchRepository
extends java.lang.Object
implements RepositoryStorable, RepositoryLifecycle

OpenSearch 矢量存储知识库

从以下版本开始:

3.4

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	OpenSearchRepository.Builder OpenSearch 知识库构建器
static class	OpenSearchRepository.IndexMethod OpenSearch 索引方法

方法概要

限定符和类型	方法和说明
static OpenSearchRepository.Builder	builder(EmbeddingModel embeddingModel, org.opensearch.client.RestHighLevelClient client) 创建 OpenSearch 知识库构建器
void	deleteById(java.lang.String... ids) 删除指定ID的文档
void	dropRepository() 注销仓库
boolean	existsById(java.lang.String id) 检查文档是否存在
void	initRepository() 初始化仓库
void	save(java.util.List<Document> documents, java.util.function.BiConsumer<java.lang.Integer,java.lang.Integer> progressCallback) 批量存储文档（支持更新）
java.util.List<Document>	search(QueryCondition condition) 搜索文档 支持向量相似度搜索和元数据过滤

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.noear.solon.ai.rag.RepositoryStorable

asyncInsert, asyncSave, delete, exists, insert, insert, insert, save, save

从接口继承的方法 org.noear.solon.ai.rag.Repository

search

方法详细资料

initRepository

public void initRepository()

初始化仓库

指定者:

initRepository 在接口中 RepositoryLifecycle

dropRepository

public void dropRepository()
                    throws java.io.IOException

注销仓库

指定者:

dropRepository 在接口中 RepositoryLifecycle

抛出:

java.io.IOException

search

public java.util.List<Document> search(QueryCondition condition)
                                throws java.io.IOException

搜索文档 支持向量相似度搜索和元数据过滤

指定者:

search 在接口中 Repository

参数:

condition - 查询条件，包含查询文本、过滤器等

返回:

匹配的文档列表

抛出:

java.io.IOException - 如果搜索过程中发生IO错误

save

public void save(java.util.List<Document> documents,
                 java.util.function.BiConsumer<java.lang.Integer,java.lang.Integer> progressCallback)
          throws java.io.IOException

批量存储文档（支持更新）

指定者:

save 在接口中 RepositoryStorable

参数:

documents - 要存储的文档列表

progressCallback - 进度回调

抛出:

java.io.IOException - 如果存储过程中发生IO错误

deleteById

public void deleteById(java.lang.String... ids)
                throws java.io.IOException

删除指定ID的文档

指定者:

deleteById 在接口中 RepositoryStorable

参数:

ids - 文档IDs

抛出:

java.io.IOException

existsById

public boolean existsById(java.lang.String id)

检查文档是否存在

指定者:

existsById 在接口中 RepositoryStorable

参数:

id - 文档ID

builder

public static OpenSearchRepository.Builder builder(EmbeddingModel embeddingModel,
                                                   org.opensearch.client.RestHighLevelClient client)

创建 OpenSearch 知识库构建器

参数:

embeddingModel - 嵌入模型

client - OpenSearch 客户端

返回:

构建器实例