Ryan-Nightwish opened a new pull request, #830: URL: https://github.com/apache/flink-agents/pull/830
<!-- * Thank you very much for contributing to Flink Agents. * Please add the relevant components in the PR title. E.g., [api], [runtime], [java], [python], [hotfix], etc. --> <!-- Please link the PR to the relevant issue(s). Hotfix doesn't need this. --> Linked issue: #822 ### Purpose of change Flink Agents supports parallel LLM invocations via multi-action fan-out, but no existing quickstart or example demonstrates this capability. This PR adds a complete "Parallel Sentiment Analysis" example (Java + Python) and a quickstart doc page covering the end-to-end workflow. **New files:** - `docs/content/docs/get-started/quickstart/parallel_llm.md` — quickstart page with code walkthrough (both Python and Java tabs), deployment instructions, and constraints for multi-action fan-out - `examples/.../ParallelChatRequestExample.java` — Java entry point - `examples/.../agents/ParallelChatAgent.java` — Java agent that fans out three `ChatRequestEvent` events (one per sentiment dimension) in parallel, collects responses via sensory memory, and aggregates with a final LLM call - `python/.../parallel_chat_request_example.py` — Python entry point - `python/.../agents/parallel_chat_agent.py` — Python equivalent of the Java agent **Modified files:** - `examples/.../agents/CustomTypesAndResources.java` — add shared types (`SentimentRequest`, `SentimentKeySelector`, `AspectResponse`, `SummaryResponse`) following project convention - `python/.../agents/custom_types_and_resources.py` — add shared types (`AspectResponse`, `SummaryResponse`) ### Tests - Verified Java example runs successfully (JDK 21, parallel execution) - Verified Python example runs successfully (conda + Python 3.11) - Both produce correct output: `taste:positive, service:negative, price:not_mentioned` ### API No public API changes. ### Documentation <!-- Do not remove this section. Check the proper box only. --> - [ ] `doc-needed` <!-- Your PR changes impact docs --> - [ ] `doc-not-needed` <!-- Your PR changes do not impact docs --> - [x] `doc-included` <!-- Your PR already contains the necessary documentation updates --> -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
