Hello,all
????????????????state??????????
&nbsp; &nbsp; &nbsp; DataStream<Tuple2<String, String&gt;&gt; result = 
iteration.closeWith(
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; 
iteration.keyBy(0).process(new RichMapFunc());



????richmapfunc????????state????????????????????????????state??????????????
????????result????????stream??????????keyby(0)??????state??????????????
??????????????????stream????keyby??????key??????????????
????map??operator????????????????keyedstream??operator????key????????????????????????keyby??????????????????

回复