CoreDao
判断flatmap、reduceByKey、GroupByKey算子的宽窄
关注作者
腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
圈层
工具
MCP广场
文章/答案/技术大牛
搜索
搜索
关闭
发布
CoreDao
社区首页
>
专栏
>
判断flatmap、reduceByKey、GroupByKey算子的宽窄
判断flatmap、reduceByKey、GroupByKey算子的宽窄
CoreDao
关注
发布于 2021-04-13 10:43:29
发布于 2021-04-13 10:43:29
597
0
举报
文章被收录于专栏:
BigData_Flink
BigData_Flink
A1 思路
添加分区参数看是否报错
看源码参数是否有与分区相关的
A2 具体
flatmap(窄):
reduceByKey(宽):
GroupByKey(宽):
A3 问题
宽窄依赖影响的是什么?
本文参与
腾讯云自媒体同步曝光计划
,分享自作者个人站点/博客。
原始发表:2021/03/10 ,如有侵权请联系
cloudcommunity@tencent.com
删除
前往查看
源码
目录
A1 思路
A2 具体
A3 问题
问题归档
专栏文章
快讯文章归档
关键词归档
开发者手册归档
开发者手册 Section 归档