Apache Flink：keyby和window运算符

"即使每个窗口实际上有多个键，每个对process/ reduce/ sum/ aggregate函数的调用都是使用具有相同键的元素进行的。

在你的示例中，你可以使用sum，Flink将负责所有事情：

text.flatMap(new Tokenizer())

  .keyBy(0)
  .window(TumblingProcessingTimeWindows.of(Time.seconds(3)))
  .sum(X)

如果你选择reduce改为......

text.flatMap(new Tokenizer())

  .keyBy(0)
  .window(TumblingProcessingTimeWindows.of(Time.seconds(3)))
  .reduce(new ReduceFunction<Tuple2<String, Integer>>(){
        @Override
        public Tuple2<String, Integer> reduce(final Tuple2<String, Integer> first, final Tuple2<String, Integer> second) {
              (... do something with the guarantee that first[0] == second[0](same key) ...)
        }
  });"