1.案例

我们先产生一个输入流，这个输入Event流由Event对象和event time组成，那么要使用EventTime，除了指定TimeCharacteristic外，在Flink中还要assignTimestampsAndWatermarks，其中分别定义了Eventtime和WaterMark，

/*** 测试结果：* {start=[Event(id=1, name=start, money=1.0)], middle=[Event(id=5, name=middle, money=5.0)], end=[Event(id=4, name=end, money=4.0)]}* 3> 1,5,4* @throws Exception*/@Testpublic void testCep