可以根据get.partitionId获得数据所在的partition 然后执行具体的rdd计算
-
信息被删除或无权限查看
- Spark RDD 能否知道指定分区数据？
- 使用 Phoenix 做用户标签效率如何？可以满足这种需求吗？
- spark-shell 执行 hc.sql ("load data inpath '/tmp/tags' overwrite into table tags") 出错，怎么解决？
- spark-shell 执行 hc.sql ("load data inpath '/tmp/tags' overwrite into table tags") 出错，怎么解决？
- spark-shell 执行 hc.sql ("load data inpath '/tmp/tags' overwrite into table tags") 出错，怎么解决？
-
信息被删除或无权限查看
-
信息被删除或无权限查看
- maven 如何导出依赖 jar 包？
- scala 的脚本放在哪？
- spark-shell 执行 hc.sql ("load data inpath '/tmp/tags' overwrite into table tags") 出错，怎么解决？
- 《Linux 多线程服务端编程》中，弱回调的 StockFactory 是如何析构的？
- java 中补码右移时如果末尾变 0 的话要加 1 吗？
- 如何评价 spark 在机器学习中的应用状况？
- Spark 配置如何处理 1G 大小的文件，做积分统计？