Hi Suxi, Do you mean you want to call the algorithm in C++ ? If so, I think you could do it the same with as you wrap it in SpringBoot project via JNI. I think you do not need to add a new operator, and you could use existing Flink API, and you could load you library in open() and call the algorithm in the following processing method.
Best, Yun ------------------Original Mail ------------------ Sender:苏喜 张 <15138217...@163.com> Send Date:Mon Mar 8 14:12:02 2021 Recipients:user@flink.apache.org <user@flink.apache.org> Subject:How do I call an algorithm written in C++ in Flink? The company has provided an algorithm written in C++, which has been packaged into a.so file. I have built a SpringBoot project, which uses JNI to operate the algorithm written in C++. Could you please tell me how to call it in Flink? Do i need to define operators, chains of operators?
