flink1.10 po extends ParentPo??print??????????print parent??????????

Fri, 08 May 2020 02:48:26 -0700 

??????PO??????????????
env.addSource(consumer)
        .uid("source")
        .setParallelism(parameterTool.getInt("source_num", 1))         
//json??????????value????????????
        .map(value -> JSONObject.parseObject(value, IPEntiy.class))
        .uid("map")
        .setParallelism(parameterTool.getInt("map_num", 
1));print??????parent??????value????

回复