客快物流大数据项目(四十七)：Spark操作Kudu Native RDD
客快物流大数据项目(四十七)：Spark操作Kudu Native RDD
Lansonli
发布于 2022-02-24 15:09:55
发布于 2022-02-24 15:09:55
目录
Spark操作Kudu Native RDD
Spark与Kudu的集成同时提供了kudu RDD
- 代码示例
val columnsList = List("id", "name", "age", "sex")
val rowRDD: RDD[Row] = kuduContext.kuduRDD(sc, TABLE_NAME, columnsList)
rowRDD.foreach(println(_))
sc.stop()
//session.read.options(kuduOptions).kudu.show()本文参与 腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。
原始发表：2022-02-24 ，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
目录