Hello,all ????????????????state?????????? DataStream<Tuple2<String, String>> result = iteration.closeWith( iteration.keyBy(0).process(new RichMapFunc());
????richmapfunc????????state????????????????????????????state?????????????? ????????result????????stream??????????keyby(0)??????state?????????????? ??????????????????stream????keyby??????key?????????????? ????map??operator????????????????keyedstream??operator????key????????????????????????keyby??????????????????