zhaoxuezhi comments

Repositories
Issues
Comments

Results 2 comments of


                                            zhaoxuezhi

flink sink 到starrocks，必须设置table-name属性吗？

谢谢，请问StarRocksSinkRowDataWithMeta写法有范例吗？网上找不到范例啊

flink sink 到starrocks，必须设置table-name属性吗？

`DataStream source = env .addSource(new MySourceJava_Json())//返回map数据，里面有两个key，database，table_name .uid("sourceStream-uid").name("sourceStream") .setParallelism(1) .map(new RichMapFunction() { @Override public StarRocksSinkRowDataWithMeta map(Map value) throws Exception { JSONObject data = JSON.parseObject(JSON.toJSONString(value)); StarRocksSinkRowDataWithMeta starRocksSinkRowDataWithMeta = new StarRocksSinkRowDataWithMeta(); starRocksSinkRowDataWithMeta.setDatabase(data.getString("database")); starRocksSinkRowDataWithMeta.setTable(data.getString("table_name"));...