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
