Re: How do I call an algorithm written in C++ in Flink?

Posted by Yun Gao on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/How-do-I-call-an-algorithm-written-in-C-in-Flink-tp42027p42034.html

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:苏喜 张 <[hidden email]>

Send Date:Mon Mar 8 14:12:02 2021

Recipients:[hidden email] <[hidden email]>

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?