我有一个要求,我需要写一个spark作业来连接prod(source hive)server a并将数据导入本地(temp hive server)进行转换并将其加载回targetprod(server b)
在前面的例子中,我们的目标数据库是oracle,所以我们使用下面的方法,这将覆盖表
aaa.write.format(“jdbc”).option(“url”,”jdbc:oracle:薄:@//uuuuuuu:0000/gsahgjj.yyy.com).option(“dbtable”,“test.try\hty”).option(“user”,“aaaaa”).option(“password”,“dsfdss”).option(“truncate”,“true”).mode(“overwrite”).save()。
对于从服务器a到服务器b的spark覆盖,我们需要给出什么样的语法。
当我试图通过jdbc建立从一个配置单元(servera)到serverb的连接时。它不起作用。。请帮忙。
1条答案
按热度按时间ifmq2ha21#
如果是远程配置单元,可以使用jdbc连接到配置单元。请获取您的hive thrift服务器url和端口详细信息,并通过jdbc进行连接。应该有用。