[Improve][seatunnel-examples][seatunnel-engine-examples] Add a usage example of embedding the zeta engine as a plugin in project #10272
Conversation
example of embedding the zeta engine as a plugin in project
| import java.util.stream.Stream; | ||
| import java.util.stream.StreamSupport; | ||
|
|
||
| /** 将SeaTunnel引擎当作工具的方式嵌入到项目中使用 */ |
There was a problem hiding this comment.
As a Apache Project, please describe it in English, thx
|
CI failed |
|
@davidzollo I have translated the Chinese description into English. Do I need to close this PR and then submit a new one instead? |
| System.err.println("jobError: " + jobResult.getError()); | ||
|
|
||
| Map<String, Object> jobMetricsSummary = server.getJobMetricsSummary(jobId); | ||
| System.err.println("------------jobMetricsSummary-------------"); |
|
Are there many such usage scenarios? Why isn't connecting with REST supported? |
| return JobMetricsParser.getJobMetrics(jobMetrics); | ||
| } | ||
|
|
||
| public static class JobMetricsParser { |
There was a problem hiding this comment.
Why is this class needed?
There was a problem hiding this comment.
SeaTunnel is a comprehensive software. However, in actual projects, the requirements I encountered were that some functions needed to achieve data transmission between different databases and collect data transmission indicators at the same time. I focused on researching DataX and SeaTunnel and found that SeaTunnel is relatively easy to be introduced into the project as a maven dependency and used as a tool rather than as a complete application, which is highly consistent with my requirements. I carefully reviewed the official documentation, drew on the implementation method of the rest api, wrote this sample code and confirmed that it was indeed feasible. Since I hadn't found similar usage experiences on the Internet before, I also asked large models like deepseek and Doubao, but still didn't get satisfactory answers. I think perhaps others might also encounter similar usage scenarios. Since I have found a feasible solution, I hope it can offer some reference to others
3 participants
Purpose of this pull request
Add a usage example of embedding the zeta engine as a plugin in project
Does this PR introduce any user-facing change?
No
How was this patch tested?
Check list
New License Guide
incompatible-changes.mdto describe the incompatibility caused by this PR.