代码采用sql方式接入mysql cdc数据然后转出Stream流, 写入kudu,但是不知道怎么去获取
row里面的主键字段是哪一个和字段名称和类型等?
或者toRetractStream可以指定其他的class???
下面是代码
======================================
tableEnv.executeSql(createTableSql);
Table table = tableEnv.sqlQuery(querySql);
DataStream<Tuple2<Boolean, Row>> dataStream =
tableEnv.toRetractStream(table, Row.class);
dataStream.print().setParallelism(1);
======================================
--
Sent from:
http://apache-flink.147419.n8.nabble.com/