关于flink cdc sql转出Stream流问题

Mon, 30 Nov 2020 00:51:24 -0800 

代码采用sql方式接入mysql cdc数据然后转出Stream流， 写入kudu，但是不知道怎么去获取
row里面的主键字段是哪一个和字段名称和类型等？
或者toRetractStream可以指定其他的class？？？

下面是代码
======================================
        tableEnv.executeSql(createTableSql);
        Table table = tableEnv.sqlQuery(querySql);
        DataStream<Tuple2&lt;Boolean, Row>> dataStream =
tableEnv.toRetractStream(table, Row.class);
        dataStream.print().setParallelism(1);
======================================



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

回复