本实例使用 Flink 的有状态流处理和滑动窗口，实现实时点击量排行榜。
该实例统计过去 1 分钟内，点击量最高的男女用户各 10 名及其具体的点击数，同时每隔 1 秒（实时）更新统计结果，等到排行榜数据并将结果同步到 kafka 中。
2022-02-24 17:08:05
3.39MB
1
本实例使用 PyFlink + Scikit-Learn 基于kafka输入的实时手写体数据，在线训练一个手写体识别机器学习模型，以及提供实时的手写体识别服务；并实现对模型训练过程的实时监控。
2022-02-24 17:08:04
3.87MB
1
本实例通过 Flink 结合 UDF 对系统上报的日志进行实时解析并生成告警，搭建实时监控告警系统
2022-02-22 14:10:58
1.59MB
1
该实例的处理过程是通过 Flink 对文件存储系统里的数据进行离线批处理，统计指定文件下的单词数，并将统计结果存储到其他文件下。
该实例业务实现过程如下：
- 首先使用 `filesystem` 作为连接器，按照指定的 `csv` 格式来批量地读取指定路径的文件或文件夹，以此创建源数据表。
- 然后，在 Flink 中执行批处理实例逻辑，完成批处理任务。
- 最后，使用 `filesystem` 连接器，将处理后结果写入目标文件或文件夹内，构建结果表。
2022-02-21 19:11:27
4KB
1
PyFlink 从入门到精通
基于 PyFlink 的学习文档，通过一个个小实践，便于小伙伴们快速入手 PyFlink
1、本地开发环境搭建
1.1、安装Flink
1.1.1、Mac
首先本地的 java 版本需要升级到 8 或 11
java -version
# 可能会看到 java version "1.8.0_111"
然后使用 brew 安装 Flink ，目前 Flink 的最新版本为 1.11.2
brew switch apache-flink 1.11.2
cd 到 /usr/local/Cellar/apache-flink/1.11.2/libexec/bin/start-cluster.sh 路径下，启动 flink
cd /usr/local/Cellar/apache-flink/1.11.2/libexec/bin
sh start-cluster.sh
启
2021-11-05 18:47:38
32.79MB
1
大数据-PyFlink
PyFlink简介及其示例
团队成员
数据集
PyFlink简介
PyFlink只是Apache Flink与Python的组合，或者更确切地说是Python上的Flink。
副题
电影/电视节目上映年与添加到Netflix年之间的平均时间差
最初，我想执行一些操作，这些操作将为我们提供行数，内存使用量，有关列的详细信息以及是否值，以及有关我的数据集的数据类型。
2021-06-08 17:18:30
1KB
1