Blink Planner Retracting Streams

Posted by John Mathews on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Blink-Planner-Retracting-Streams-tp36024.html

Hello,

I am working on migrating from the flink table-planner to the new blink one, and one problem I am running into is that it doesn't seem like Blink has a concept of a CRow, unlike the original table-planner.

I am therefore struggling to figure out how to properly convert a retracting stream to a SingleOutputStreamOperator when using just the Blink planner libraries.

E.g. in the old planner I could do something like this: 

SingleOutputStreamOperator<CRow> stream = tableEnvironment.toRetractStream(table, typeInfo)

                    .map(value -> new CRow(value.f1, value.f0);

but without the CRow, I'm not sure how to accomplish this.

Any suggestions?

Thanks!

John