Flink学习24:窗口的分配器

方法一：
ds.keyBy(0)
  .window(TumblingProcessingTimeWindows.of(Time.seconds(4)))
  .sum(1)

方法二：

第1步：

env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime)

第2步：

ds.keyBy(0)
  //base on Tumbling  and process windows
  .timeWindow(Time.seconds(1))
  .sum(1)