Flink| ProcessFunction API（底层API）
ProcessFunction API 之前的转换算子 是无法访问事件的时间戳信息和 水位线 信息的。而这在一些应用场景下极为重要。例如 MapFunction 这样的 map 转换算子就无法访问时间戳或者当前事件的事件时间。基于此， DataStream API 提供 ...
原文：Flink ProcessFunction API
我们之前学习的转换算子是无法访问事件的时间戳信息和水位线信息的。而这在一些应用场景下，极为重要。 例如MapFunction这样的map转换算子就无法访问时间戳或者当前事件的事件时间。 基于此，DataStream API提供了一系列的Low Level转换算子。 可以访问时间戳 watermark以及注册定时事件。还可以输出特定的一些事件，例如超时事件等。 Process Function用来构 ...
2020-04-04 15:13 0 2204 推荐指数：
相关推荐
Flink中的window、watermark和ProcessFunction(三)
一、Flink中的window 1，window简述 window 是一种切割无限数据为有限块进行处理的手段。Window 是无限数据流处理的核心，Window 将一个无限的 stream 拆分成有限大小的”buckets”桶，我们可以在这些桶上做计算操作。 2，window类型 ...
Flink之ProcessFunction侧输出流
1、代码案例 ...
Flink处理函数实战之二：ProcessFunction类
欢迎访问我的GitHub https://github.com/zq2599/blog_demos 内容：所有原创文章分类汇总及配套源码，涉及Java、Docker、Kubernetes、DevOPS等； Flink处理函数实战系列链接 深入了解ProcessFunction的状态 ...
Flink之ProcessFunction的使用（1）：定时器和状态管理的使用
相关文章链接 Flink之ProcessFunction的使用（1）：定时器和状态管理的使用 Flink之ProcessFunction的使用（2）：侧输出流的使用 具体实现代码如下所示： main函数中代码如下： 自定义类实现KeyedProcessFunction接口 ...
Flink处理函数实战之一：深入了解ProcessFunction的状态(Flink-1.10)
)：https://github.com/zq2599/blog_demos Flink处理函数实战系列链 ...
Flink基本的API
Flink使用 DataSet 和 DataStream 代表数据集。DateSet 用于批处理，代表数据是有限的；而 DataStream 用于流数据，代表数据是无界的。数据集中的数据是不可以变的，也就是说不能对其中的元素增加或删除。我们通过数据源创建 DataSet 或者 DataStream ...
Flink StreamExecutionEnvironment API
Flink流式处理API流程图 创建一个执行环境,表示当前执行程序的上下文,类似于SparkContext. 如果程序是独立调用的,则此方法返回本地执行环境.;如果从命令行客户端调用程序以提交到集群,则此方法返回此集群的执行环境. 案例:读取摄氏度 Source:从集合 ...