Flink技术灵活使用总结(四)常见案例代码_flink应用代码哪里找得到

目录

前置知识

Process Function

网站总浏览量（PV）的统计

网站独立访客数（UV）的统计

页面广告点击量统计

不同渠道的用户行为统计

不同省份的用户点击量

订单实时对账

广告点击统计

前置知识

Process Function

转换算子是无法访问事件的时间戳信息和水位线信息的。而这在一些应用场景下，极为重要。例如MapFunction这样的map转换算子就无法访问时间戳或者当前事件的事件时间。

DataStream API提供了一系列的Low-Level转换算子。可以访问时间戳、watermark以及注册定时事件。还可以输出特定的一些事件，例如超时事件等。Process Function用来构建事件驱动的应用以及实现自定义的业务逻辑(使用之前的window函数和转换算子无法实现)。例如，Flink SQL就是使用Process Function实现的。

Flink提供了8个Process Function：

• ProcessFunction
• KeyedProcessFunction
• CoProcessFunction
• ProcessJoinFunction
• BroadcastProcessFunction
• KeyedBroadcastProcessFunction

以下代码涉及的知识点较多属于高密度知识点灵活应用，有条件可以找相关的视频讲解结合理解效果更佳