华为云首页用户手册

MapReduce服务 MRS-scala:Flink常用接口

MapReduce服务 MRS-scala:Flink常用接口

时间：2023-11-01 16:19:45

MapReduce服务 MRS

Flink常用接口

Flink主要使用到如下这几个类：

StreamExecutionEnvironment：是Flink流处理的基础，提供了程序的执行环境。
DataStream：Flink用特别的类DataStream来表示程序中的流式数据。用户可以认为它们是含有重复数据的不可修改的集合(collection)，DataStream中元素的数量是无限的。
KeyedStream：DataStream通过keyBy分组操作生成流，数据经过对设置的key值进行分组。
WindowedStream：KeyedStream通过window窗口函数生成的流，设置窗口类型并且定义窗口触发条件，然后在窗口数据上进行一些操作。
AllWindowedStream：DataStream通过window窗口函数生成的流，设置窗口类型并且定义窗口触发条件，然后在窗口数据上进行一些操作。
ConnectedStreams：将两条DataStream流连接起来并且保持原有流数据的类型，然后进行map或者flatMap操作。
JoinedStreams：在窗口上对数据进行等值join操作，join操作是coGroup操作的一种特殊场景。
CoGroupedStreams：在窗口上对数据进行coGroup操作，可以实现流的各种join类型。

图1 Flink Stream的各种流类型转换

上一篇：MapReduce服务 MRS-scala:提供分流能力

下一篇：MapReduce服务 MRS-scala:提供分流能力

MapReduce服务 MRS-scala:Flink常用接口

意见反馈

0/200

提交成功！非常感谢您的反馈，我们会继续努力做到更好反馈提交失败！请稍后重试！

推荐文章

解决方案
相关专题