使用map遍历RDD[Row],然后使用mkString切割得到RDD[String]
后续如果想要存入库中可以使用隐式函数转dataframe进行相关操作
上一篇 Spark基础案例之单词统计WordCount
下一篇 ElasticSearch ES 安装 常见错误 Kibana安装 设置 权限 密码
版权所有 (c)2021-2022 MSHXW.COM
ICP备案号:晋ICP备2021003244-6号