????flink????state

[???????L]

import org.apache.flink.api.java.functions.KeySelector; import 
org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows; 
import org.apache.flink.streaming.api.windowing.time.Time;   ... 
DataStream<Integer&gt; orangeStream = ... DataStream<Integer&gt; greenStream = 
... orangeStream.join(greenStream)     .where(<KeySelector&gt;)     
.equalTo(<KeySelector&gt;)     
.window(TumblingEventTimeWindows.of(Time.milliseconds(2)))     .apply (new 
JoinFunction<Integer, Integer, String&gt; (){         @Override         public 
String join(Integer first, Integer second) {             return first + "," + 
second;         }     });????????????, 
????richJoinFunction????valueState,???????????????????? 
????state????????????????????????????????, ?????????????????????