实时计算 Flink版

首页 标签 实时计算 Flink版
祝贺!两位 Apache Flink PMC 喜提 Apache Member
目前,国内(华人)近 30 位 Apache Member 中,有 3 位是 Apache Flink 的核心贡献者。他们热爱开源也为开源贡献,不仅积极参与社区与其他 PMC 成员共同规划、主导 Apache Flink 的发展,更活跃在多个开源项目,持续为开源社区做贡献。
Flink1.7.2 local WordCount源码分析
Flink 环境 local,版本 Flink.1.7.2 用官网示例WordCount Scala程序分析源码 本文从source、operator、sink三个方面详细分析Flink源码实现
Flink实战(五) - DataStream API编程
1 概述 Flink中的DataStream程序是实现数据流转换的常规程序(例如,过滤,更新状态,定义窗口,聚合)。 最初从各种源(例如,消息队列,套接字流,文件)创建数据流。 结果通过接收器返回,接收器可以例如将数据写入文件或标准输出(例如命令行终端)。
链路层的双链路--大型服务器的优化体系
链路层的双链路--大型服务器的优化体系 一直在潜水,不过朋友可在相关QQ群找我,哈也可以加我工作QQ; 之前有朋友问过,链路层的东西,其实很抽象,刚好看到相关的内容,在此分享一下;   可以参考下面的文章: 0.
Flink实战(三) - 编程范式及核心概念
1 基本的 API 概念 Flink程序是实现分布式集合转换的常规程序(例如,过滤,映射,更新状态,加入,分组,定义窗口,聚合)。最初从源创建集合(例如,通过从文件,kafka主题或从本地的内存集合中读取)。
Flink流处理之迭代API分析
IterativeStream Flink在DataStream中也是通过一个特定的可迭代的流(IterativeStream)来构建相关的迭代处理逻辑,这一点跟DataSet提供的可迭代的数据集(IterativeDataSet)的是类似的。
免费试用