事件时间
在本节中,您将学习如何编写时间感知的Flink程序。请看一下及时流处理,了解及时流处理背后的概念。
关于如何在Flink程序中使用时间的信息请参考windowing和ProcessFunction。
需要注意的是,为了使用事件时间感知操作,程序需要使用直接为数据定义事件时间并自己发射水印的源,或者程序必须在源之后注入一个时间戳分配器&水印生成器。这些函数描述了如何访问事件时间戳,以及事件流表现出何种程度的无序性。
下一步去哪里?
- Generating Watermarks: Shows how to write timestamp assigners and watermark generators, which are needed for event-time aware Flink applications.
- Builtin Watermark Generators: Gives an overview of the builtin watermark generators.
- Debugging Windows & Event Time: Show how to debug problems around watermarks and timestamps in event-time Flink applications.