基于storm的Window

Watermark作用 在解释storm的window之前先说明一下watermark原理。 Watermark中文翻译为水位线更为恰当。 顺序的数据从源头开始发送到到操作，中间过程肯定会出现数据乱序情况，比如网络原因，数据并发发送等。如何区分乱序的数据和正常的数据，就引申出了watermark。 Watermark是每一个时间窗口的下限，意思是说当watermark大于了窗口截止时间，那么该窗口

>>阅读原文<<