-1,
@tison, sorry, I can't get your point, please describe it again. how does it differentiate to what StreamPipes does? and how does it differentiate to what Apache Inlong does? These are all handle stream calculation, why not expand the function and create a new project instead?
