假定Session時間設為5秒，那么只要5秒內保持數據流入，那么就認為數據Session沒有中斷，否則就劃分一個Session。 ``` 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 ``` 兩個數據之間的距離不超過5秒，就在一個Session中。 ```java public class SessionWindowAll { private static final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); private static final DataStreamSource<String> stream = env.socketTextStream("192.168.8.111", 8888); public static void main(String[] args) throws Exception { SingleOutputStreamOperator<Integer> mapped = stream.map((MapFunction<String, Integer>) Integer::valueOf).returns(Types.INT); AllWindowedStream<Integer, TimeWindow> processingTimeSessionWindows = mapped.windowAll(ProcessingTimeSessionWindows.withGap(Time.seconds(5))); SingleOutputStreamOperator<Integer> summed = processingTimeSessionWindows.sum(0); summed.print(); env.execute("SessionWindowAll"); } } ``` 換句話說，輸入一個數據超過`5`秒，就會計算結果。