Flink实战(五) - DataStream API编程
1 概述
Flink中的DataStream程序是实现数据流转换的常规程序(例如,过滤,更新状态,定义窗口,聚合)。
最初从各种源(例如,消息队列,套接字流,文件)创建数据流。
结果通过接收器返回,接收器可以例如将数据写入文件或标准输出(例如命令行终端)。
链路层的双链路--大型服务器的优化体系
链路层的双链路--大型服务器的优化体系
一直在潜水,不过朋友可在相关QQ群找我,哈也可以加我工作QQ;
之前有朋友问过,链路层的东西,其实很抽象,刚好看到相关的内容,在此分享一下;
可以参考下面的文章:
0.
Flink实战(三) - 编程范式及核心概念
1 基本的 API 概念
Flink程序是实现分布式集合转换的常规程序(例如,过滤,映射,更新状态,加入,分组,定义窗口,聚合)。最初从源创建集合(例如,通过从文件,kafka主题或从本地的内存集合中读取)。
Flink流处理之迭代API分析
IterativeStream
Flink在DataStream中也是通过一个特定的可迭代的流(IterativeStream)来构建相关的迭代处理逻辑,这一点跟DataSet提供的可迭代的数据集(IterativeDataSet)的是类似的。