知识卡片

ProcessFunction贴近底层

专业/工作 · 502.j

内容

ProcessFunction 能访问时间、状态、定时器(见[[Timer是时间回调]])和侧输出(见[[侧输出分流异常]]),是 DataStream 中更底层的处理接口。发散:高阶窗口 API 不够表达时,ProcessFunction 是回到底层语义的出口。

参考来源

- 位置:《Flink原理与实践》第5章《时间和窗口》(源文件:_epub-src/OEBPS/Text/chapter08.xhtml) - 结论依据:原文围绕“Flink最底层的API:ProcessFunction”给出定义、流程、对比或限制条件,本卡片据此提炼其可迁移的框架机制,并补充了使用边界或工程启发。 - 原始内容:绍Flink的时间和窗口相关知识,通过本章的学习,读者可以了解下面的知识。 Flink的时间语义。 Flink最底层的API:ProcessFunction。 窗口以及窗口上的计算。 数据流上的Join操作。 处理迟到数据。 本章的实验中,我们仍然以股票价格数据流为例,对其进行窗口上的各类操作。读者……