我试图计算流中的元素，同时用窗口的结束时间丰富结果。
使用flink提供的kafka10消费者从kafka接收事件。使用eventtime。一个简单的keyedstream.count（…）很好用。这条小溪长4分钟。通过使用3分钟的时间窗口，只接收一个输出。应该有两个。结果是用bucketingsink写的。

val count = stream.map( m => (m.getContext, 1) )
    .keyBy( 0 )
    .timeWindow( Time.minutes(3) )
    .apply( new EndTimeWindow() )
    .map( new JsonMapper() )
count.addSink( countSink )

class EndTimeWindow extends WindowFunction[(String,Int),(String, Int),Tuple, TimeWindow]{
    override def apply(key: Tuple, window: TimeWindow, input: Iterable[(String, Int)], out: Collector[(String, Int)]): Unit =  {
        var sum: Int = 0
        for( value <-input ) {
            sum = sum + value._2;
        }
        out.collect( (window.getEnd.toString, new Integer(sum ) ))
    }
}

通过使用3分钟的时间窗口，只接收一个事件量较小的输出。应该有两个输出。