Re: Blink Planner Retracting Streams

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

hi John,

You can use Tuple2[Boolean, Row] to replace CRow, the StreamTableEnvironment#toRetractStream method return DataStream[(Boolean, T)].

the code looks like:

tEnv.toRetractStream[Row](table).map(new MapFunction[(Boolean, Row), R] {
      override def map(value: (Boolean, Row)): R = ...
    })

Bests,

Godfrey

John Mathews <[hidden email]> 于2020年6月17日周三 下午12:13写道：

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