Hi,

There are APIs to convert a dynamic table to retract stream. Is there any way 
to construct a "retract" data stream and convert it into table? I want to read 
the change log of relational database from kafka, "apply" the changes within 
flink( by creating CRow DataStream), register/create a table on the CRow 
DataStream. Is there any way to do this?


Best

Yan

Reply via email to