This is an automated email from the ASF dual-hosted git repository.
wenjin272 pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-agents.git
from 985c6d80 [ci] Remove invalid api key.
new 918004bb [api][integrations] Remove VectorStoreLongTermMemory and
refactor vector store API
new 3a828071 [api][runtime] Implement Mem0LongTermMemory on the Java side
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../agents/api/memory/BaseLongTermMemory.java | 101 +++---
.../agents/api/memory/LongTermMemoryOptions.java | 35 +--
.../apache/flink/agents/api/memory/MemorySet.java | 120 +++-----
.../flink/agents/api/memory/MemorySetItem.java | 64 ++--
.../api/memory/compaction/CompactionConfig.java | 92 ------
.../api/resource/python/PythonResourceAdapter.java | 9 -
.../agents/api/vectorstores/BaseVectorStore.java | 226 ++++++++++++--
.../CollectionManageableVectorStore.java | 46 +--
.../flink/agents/api/vectorstores/Document.java | 36 ++-
.../agents/api/vectorstores/VectorStoreQuery.java | 44 ++-
.../PythonCollectionManageableVectorStore.java | 35 +--
.../api/vectorstores/python/PythonVectorStore.java | 65 +++-
.../flink/agents/api/memory/MemorySetTest.java | 10 +-
.../PythonCollectionManageableVectorStoreTest.java | 133 ++++----
.../test/VectorStoreLongTermMemoryAgent.java | 182 -----------
.../test/VectorStoreLongTermMemoryTest.java | 330 --------------------
.../pom.xml | 11 +
.../resource/test/Mem0LongTermMemoryAgent.java | 260 ++++++++++++++++
.../resource/test/Mem0LongTermMemoryTest.java | 182 +++++++++++
.../test/VectorStoreCrossLanguageAgent.java | 52 +++-
.../elasticsearch/ElasticsearchVectorStore.java | 341 +++++++++------------
.../ElasticsearchVectorStoreTest.java | 148 +++++++--
.../opensearch/OpenSearchVectorStore.java | 205 +++++++------
.../opensearch/OpenSearchVectorStoreTest.java | 132 +++++++-
.../s3vectors/S3VectorsVectorStore.java | 96 ++++--
.../s3vectors/S3VectorsVectorStoreTest.java | 86 +++++-
.../apache/flink/agents/plan/actions/Utils.java | 3 +
.../vector_store_cross_language_agent.py | 38 ++-
.../flink_agents/runtime/java/java_vector_store.py | 84 ++---
python/flink_agents/runtime/python_java_utils.py | 38 +++
runtime/pom.xml | 8 +
.../agents/runtime/context/RunnerContextImpl.java | 16 +-
.../agents/runtime/memory/CompactionFunctions.java | 215 -------------
.../agents/runtime/memory/Mem0LongTermMemory.java | 182 +++++++++++
.../runtime/memory/VectorStoreLongTermMemory.java | 314 -------------------
.../runtime/operator/ActionExecutionOperator.java | 67 +++-
.../runtime/python/utils/JavaResourceAdapter.java | 23 +-
.../runtime/python/utils/PythonActionExecutor.java | 4 +
.../python/utils/PythonResourceAdapterImpl.java | 9 -
.../flink/agents/runtime/ResourceCacheTest.java | 7 -
.../runtime/memory/Mem0LongTermMemoryTest.java | 240 +++++++++++++++
41 files changed, 2302 insertions(+), 1987 deletions(-)
delete mode 100644
api/src/main/java/org/apache/flink/agents/api/memory/compaction/CompactionConfig.java
delete mode 100644
e2e-test/flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/VectorStoreLongTermMemoryAgent.java
delete mode 100644
e2e-test/flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/VectorStoreLongTermMemoryTest.java
create mode 100644
e2e-test/flink-agents-end-to-end-tests-resource-cross-language/src/test/java/org/apache/flink/agents/resource/test/Mem0LongTermMemoryAgent.java
create mode 100644
e2e-test/flink-agents-end-to-end-tests-resource-cross-language/src/test/java/org/apache/flink/agents/resource/test/Mem0LongTermMemoryTest.java
delete mode 100644
runtime/src/main/java/org/apache/flink/agents/runtime/memory/CompactionFunctions.java
create mode 100644
runtime/src/main/java/org/apache/flink/agents/runtime/memory/Mem0LongTermMemory.java
delete mode 100644
runtime/src/main/java/org/apache/flink/agents/runtime/memory/VectorStoreLongTermMemory.java
create mode 100644
runtime/src/test/java/org/apache/flink/agents/runtime/memory/Mem0LongTermMemoryTest.java
