(flink-agents) branch main updated (8d14972 -> 8825795)

[xt...@apache.org]

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 8d14972  [runtime] Remove userCodeClassLoader field for ActionTask to fix can't be serialized to state. (#379)
     add 8825795  [Feature][Integration][Java] add ElasticsearchVectorStore in Java (#341)

No new revisions were added by this update.

Summary of changes:
 .../annotation/{Prompt.java => VectorStore.java}   |  10 +-
 .../api/event/ContextRetrievalRequestEvent.java    |  69 +++++
 ...ent.java => ContextRetrievalResponseEvent.java} |  36 ++-
 .../agents/api/vectorstores/BaseVectorStore.java   |  92 ++++++
 .../flink/agents/api/vectorstores/Document.java    |  48 ++--
 .../agents/api/vectorstores/VectorStoreQuery.java  |  93 ++++++
 .../api/vectorstores/VectorStoreQueryMode.java     |  24 +-
 .../VectorStoreQueryResult.java}                   |  34 +--
 .../pom.xml                                        |   5 +
 .../test/VectorStoreIntegrationAgent.java          | 156 ++++++++++
 .../test/VectorStoreIntegrationTest.java           | 121 ++++++++
 integrations/pom.xml                               |   2 +
 .../elasticsearch}/pom.xml                         |  15 +-
 .../elasticsearch/ElasticsearchVectorStore.java    | 316 +++++++++++++++++++++
 .../{embedding-models => vector-stores}/pom.xml    |   8 +-
 .../org/apache/flink/agents/plan/AgentPlan.java    |  11 +-
 .../plan/actions/ContextRetrievalAction.java       |  72 +++++
 .../apache/flink/agents/plan/AgentPlanTest.java    |   8 +-
 .../create_python_agent_plan_from_json.py          |   4 +-
 19 files changed, 1043 insertions(+), 81 deletions(-)
 copy api/src/main/java/org/apache/flink/agents/api/annotation/{Prompt.java => VectorStore.java} (72%)
 create mode 100644 api/src/main/java/org/apache/flink/agents/api/event/ContextRetrievalRequestEvent.java
 copy api/src/main/java/org/apache/flink/agents/api/event/{ChatResponseEvent.java => ContextRetrievalResponseEvent.java} (54%)
 create mode 100644 api/src/main/java/org/apache/flink/agents/api/vectorstores/BaseVectorStore.java
 copy runtime/src/main/java/org/apache/flink/agents/runtime/message/EventMessage.java => api/src/main/java/org/apache/flink/agents/api/vectorstores/Document.java (51%)
 create mode 100644 api/src/main/java/org/apache/flink/agents/api/vectorstores/VectorStoreQuery.java
 copy runtime/src/main/java/org/apache/flink/agents/runtime/queue/Lock.java => api/src/main/java/org/apache/flink/agents/api/vectorstores/VectorStoreQueryMode.java (57%)
 copy api/src/main/java/org/apache/flink/agents/api/{resource/Resource.java => vectorstores/VectorStoreQueryResult.java} (55%)
 create mode 100644 e2e-test/flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/VectorStoreIntegrationAgent.java
 create mode 100644 e2e-test/flink-agents-end-to-end-tests-integration/src/test/java/org/apache/flink/agents/integration/test/VectorStoreIntegrationTest.java
 copy integrations/{chat-models/anthropic => vector-stores/elasticsearch}/pom.xml (79%)
 create mode 100644 integrations/vector-stores/elasticsearch/src/main/java/org/apache/flink/agents/integrations/vectorstores/elasticsearch/ElasticsearchVectorStore.java
 copy integrations/{embedding-models => vector-stores}/pom.xml (87%)
 create mode 100644 plan/src/main/java/org/apache/flink/agents/plan/actions/ContextRetrievalAction.java