How to Implement a Runner for C++ Streaming Processing Engine？

[邵凯]

I have a streaming processing engine implemented in C++. Do you have any good 
plans and suggestions to implement a runner?
I looked at the Beam Runner implementation guide and felt that I couldn't 
implement a Runner for a C++ streaming data processing engine. Because I can't 
let the C++ streaming data processing engine execute beam pipeline if I 
implement Runner in java.