没有合适的资源?快使用搜索试试~ 我知道了~
play-with-flink
共36个文件
class:9个
csv:8个
java:5个
需积分: 9 0 下载量 200 浏览量
2021-05-03
02:54:49
上传
评论
收藏 1.78MB ZIP 举报
温馨提示
随心所欲玩 关于Apache Flink批处理功能的示例项目,例如连接/组示例 项目将使用从以下链接下载的示例数据 链接包含的数据文件很少,我们正在使用电影和评级数据集文件。 它有两个示例: FlinkDramaMovieParser.java FlinkJoinByGroupByExample.java FlinkDramaMovieParser:示例将解析电影数据集并仅过滤出戏剧电影。 FlinkJoinByGroupByExample:示例将展示如何在数据集上使用apache flink的功能进行联接和分组。 它将合并两个数据集“电影”和“评级”。 将加入结果按特定流派按平均评分分组。 最终将结果
资源推荐
资源详情
资源评论
收起资源包目录
play-with-flink-master.zip (36个子文件)
play-with-flink-master
pom.xml 8KB
target
classes
README.txt 8KB
META-INF
maven
com.bny.demo
play-with-flink
pom.xml 8KB
pom.properties 230B
MANIFEST.MF 103B
ratings.csv 2.23MB
log4j.properties 1KB
com
bny
demo
flink
FlinkDramaMovieParser.class 2KB
FlinkJoinByGroupByExample$1.class 2KB
FlinkJoinByGroupByExample$2.class 3KB
FlinkDramaMovieParser$2.class 1KB
FlinkJoinByGroupByExample.class 6KB
FlinkDramaMovieParser$1.class 2KB
StreamingJob.class 879B
modal
Movie.class 2KB
BatchJob.class 794B
tags.csv 40KB
movies.csv 439KB
links.csv 170KB
.settings
org.eclipse.m2e.core.prefs 86B
org.eclipse.core.resources.prefs 55B
org.eclipse.jdt.core.prefs 203B
src
main
resources
README.txt 8KB
ratings.csv 2.23MB
log4j.properties 1KB
tags.csv 40KB
movies.csv 439KB
links.csv 170KB
java
com
bny
demo
flink
FlinkDramaMovieParser.java 2KB
FlinkJoinByGroupByExample.java 3KB
modal
Movie.java 704B
StreamingJob.java 2KB
BatchJob.java 2KB
.project 649B
.classpath 5KB
README.md 723B
共 36 条
- 1
资源评论
应聘
- 粉丝: 29
- 资源: 4568
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功