数据分析领域正在见证许多用例从批处理到流处理的演变。尽管批处理可以被作为流处理的一个特殊例子，处理永不结束的流式数据通常需要转换思维方式且通常有自己的术语（例如“窗口”和“最少一次/只有一次”处理）。这对于新接触流处理的人来说可能会相当疑惑。Flink是一个可用于生产的流处理器，具有易于使用但有表现力的API来构建高级流式分析程序。Flink的API在数据流窗口的定义十分灵活，使其从其他开源流处理器中脱颖而出。   在这篇文章中，我们将讨论流式处理窗口的概念，展示Flink内置窗口并解释其对自定义窗口语义的支持。 什么是窗口，窗口有什么用？ &ems […]