Flink 流处理-- 小技巧

本文主要是介绍Flink 流处理-- 小技巧，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

01

        //3. 将读取出来的json字符串转换为ItcastDataObj
        SingleOutputStreamOperator<ItcastDataObj> vehicleDataStream = source.map(
                new MapFunction<String, ItcastDataObj>() {
                    @Override
                    public ItcastDataObj map(String line) throws Exception {
                        return JsonParseUtil.parseJsonToObject(line);
                    }
                }
        );
        //-- 另种写法
        DataStream<ItcastDataObj> vehicleDataStream02 = source.map(JsonParseUtil::parseJsonToObject);

这篇关于Flink 流处理-- 小技巧的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！