Re: 关于flink cdc sql转出Stream流问题

[Jark Wu]

row 里面的数据就是你 schema 中定义的字段和顺序，可以按下标取值。

On Tue, 1 Dec 2020 at 13:59, jsqf  wrote:

> 可以使用这种方式:
> DataStream dstream = tableEnv.toAppendStream(sourceTable,
> RowData.class);
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>

Re: 关于flink cdc sql转出Stream流问题

[jsqf]

可以使用这种方式:
DataStream dstream = tableEnv.toAppendStream(sourceTable,
RowData.class);



--
Sent from: http://apache-flink.147419.n8.nabble.com/