达州做网站
大橙子网站建设，新征程启航
为企业提供网站建设、域名注册、服务器等服务
SparkSQL读取MySQL的dept和hive的emp表，做join和分组查询，后写到json
val jdbcDF = spark.read.format("jdbc").option("url", "jdbc:MySQL://hadoop000:3306").option("dbtable", "hive.dept").option("user", "root").option("password", "123456").load()
jdbcDF.createOrReplaceTempView("dept")
val hiveDF = sql("SELECT * FROM emp")
val sqlDF = sql("SELECT * FROM emp e JOIN dept d ON e.deptno = d.deptno").show
sqlDF.write.format("json").save("file:///empJoinDept.json")本文题目：SparkSQL读取MySQL的dept和hive的emp表，做join和分组查询，后写到json
文章分享：http://dzwzjz.com/article/piehpe.html