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
