Flink系列之Time和WaterMark

　　当数据进入Flink的时候，数据需要带入相应的时间，根据相应的时间进行处理。 　　让咱们想象一个场景，有一个队列，分别带着指定的时间，那么处理的时候，需要根据相应的时间进行处理，比如：统计最近五分钟的访问量，那么就需要知道数据到来的时间。五分钟以内的数据将会被计入，超过五分钟的将会计入下一个计算窗口。 　　那么Flink的Time分为三种： 　　ProcessingTime ： 处理时间，即算

>>阅读原文<<