This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-agents.git
from 71b8bff [doc] Add doc for ElasticsearchVectorStore in java (#397)
new 83ce09b [runtime] Support using JavaChatModelConnection directly in
Python
new c990501 [feature] Support Python resource retrieval through the Java
resource using the getResource function
new 01362a6 [feature] Support Java resource retrieval through the Python
resource using the get_resource function
new c9e03cb [Feature][runtime] Support the use of Java EembeddingModel in
Python
The 4 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:
dist/pom.xml | 5 +
.../pom.xml | 5 +
.../resource/test/ChatModelCrossLanguageAgent.java | 39 ++++++-
.../resourceprovider/PythonResourceProvider.java | 39 +++++--
.../apache/flink/agents/plan/AgentPlanTest.java | 3 +-
.../api/embedding_models/embedding_model.py | 2 +-
.../java_embedding_model.py} | 29 ++---
python/flink_agents/api/events/chat_event.py | 2 +-
.../chat_model_cross_language_agent.py | 17 ++-
.../embedding_model_cross_language_agent.py | 123 +++++++++++++++++++++
...t.py => embedding_model_cross_language_test.py} | 16 +--
python/flink_agents/plan/resource_provider.py | 2 +
.../flink_agents/runtime/java/java_chat_model.py | 43 +++++--
.../runtime/java/java_embedding_model.py | 107 ++++++++++++++++++
python/flink_agents/runtime/python_java_utils.py | 24 +++-
.../runtime/operator/ActionExecutionOperator.java | 24 +++-
.../runtime/python/utils/JavaResourceAdapter.java | 61 +---------
.../python/utils/PythonResourceAdapterImpl.java | 35 +++++-
.../utils/PythonResourceAdapterImplTest.java | 11 +-
19 files changed, 465 insertions(+), 122 deletions(-)
copy python/flink_agents/api/{chat_models/java_chat_model.py =>
embedding_models/java_embedding_model.py} (57%)
create mode 100644
python/flink_agents/e2e_tests/e2e_tests_resource_cross_language/embedding_model_cross_language_agent.py
copy
python/flink_agents/e2e_tests/e2e_tests_resource_cross_language/{chat_model_cross_language_test.py
=> embedding_model_cross_language_test.py} (87%)
create mode 100644 python/flink_agents/runtime/java/java_embedding_model.py
