请稍等 ...
×

采纳答案成功!

向帮助你的同学说点啥吧!感谢那些助人为乐的人

idea 可以直接 连接到 hive吗

pk哥 我看你视频 下面的代码 也没有 连接 hive 的一些配置 它是怎样 连接到 hive的
而且还 在代码里 经过业务逻辑后 还能把数据 落地到 hive 里 ???

package com.imooc.bigdata.chapter06
import java.util.Properties
import org.apache.spark.sql.SparkSession
object HiveSourceApp {
def main(args: Array[String]): Unit = {
// 如果你想使用Spark来访问Hive的时候,一定需要开启Hive的支持
val spark: SparkSession = SparkSession.builder().master(“local”).appName(“HiveSourceApp”)
.enableHiveSupport() //切记:一定要开启
.getOrCreate()
// 走的就是连接 default数据库中的pk表,如果你是其他数据库的,那么也采用类似的写法即可
spark.table(“default.pk”).show()
spark.stop()
}
}

正在回答 回答被采纳积分+3

1回答

Michael_PK 2023-03-12 23:07:26

1)你可以把hive-site.xml放到你idea的resources下,注意,一定要开启hive的metastore服务,

hive-site.xml中要有

        <property>

                <name>hive.metastore.uris</name>

                <value>thrift://hadoop000:9083</value>

        </property>

这个配置。


2) 处理完的可以落入hive的,比如saveAsTable等



0 回复 有任何疑惑可以回复我~
问题已解决,确定采纳
还有疑问,暂不采纳
微信客服

购课补贴
联系客服咨询优惠详情

帮助反馈 APP下载

慕课网APP
您的移动学习伙伴

公众号

扫描二维码
关注慕课网微信公众号