我正在尝试将火花数据帧写入MYSQL表。我尝试了以下方法:
dataFrame.write().mode(SaveMode.Append).format(JDBC).options(options);
options是以下键值对的映射:
表'tableName'未更新,并且在Spark控制台中未收到任何错误。有人可以帮我弄这个吗?
因为方法名称和地图名称相同,所以请通过更改地图名称来尝试。我不确定,但这可能是问题所在。
其次,我将选项参数声明为单独的变量,并将其传递给选项方法。
`
url_name = "xxxx"
driver_name = "xxxx"
username = "x"
passwd = "123"
dataFrame.write().mode(SaveMode.Append).format(JDBC).options(url=url_name, driver = driver_name, dbtable = query, user=username, password=passwd);
`
最后一件事,请检查.save()
选项方法之后的方法,因为您没有保存。
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句