wenjin272 opened a new pull request, #48: URL: https://github.com/apache/flink-agents/pull/48
Linked issue: #19 ### Purpose of change Support DataStream / Table as input / output of Flink Agents in Python Please note that this PR depends on #45 and #47 , so it should be merged after these PRs are merged. The first 6 commits in this PR actually belong to the prerequisite PRs. And the No.7 commit is to solve the workflow plan compatibility between Python and Java, which should be done in #45 . You can start the review from the No.8 commit (currently the last commit). ### Tests Tested manually; Currently, I add an example to validate the execution, I will add e2e test case later. ### API Yes, add from_datastream and to_datastream in AgentsExecutionEnvironment to integrate DataStream with agents. ### Documentation I will add documentations later. -- 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]
