作者是通过metastore方式实现spark连接hive数据库,所以首先启动metastore:

hive --service metastore

另外需要将core-site.xml、hdfs-site.xml、hive-site.xml三个文件复制到的spark/conf文件夹下。

image.png

hive-site.cml中要包含metastore的地址:

image.png

spark代码:

# -*- coding: utf-8 -*-

from pyspark.sql import SparkSession

spark = SparkSession\

.builder\

.appName('spark read hive')\

.master('local')\

.enableHiveSupport()\

.getOrCreate()

hive_data = spark.sql("show databases")

hive_data.show()

# 读数据库

read_data = spark.sql("select * from database.table limit 10")

read_data.show()

# 写数据库 append:追加模式;overwrite:清空表重写

read_data.write.format("hive").mode("append").saveAsTable('database.table2')

本篇spark连接的是本机hive,若是远程连接参考spark远程读写hive数据库

spark代码连接hive_spark连接Hive相关推荐

  1. spark代码连接hive_Spark SQL入门到实战之(7)spark连接hive(spark-shell和eclipse两种方式)...

    1.在服务器(虚拟机)spark-shell连接hive 1.1 将hive-site.xml拷贝到spark/conf里 cp /opt/apache-hive-2.3.2-bin/conf/hiv ...

  2. spark代码连接hive_spark SQL学习(spark连接hive)

    spark 读取hive中的数据 scala> import org.apache.spark.sql.hive.HiveContext import org.apache.spark.sql. ...

  3. mapreduce复制连接的代码_我的 Hive 为什么跑不起来/跑得慢?看看是不是少了这几行代码?...

    <饮食男女>开头说:"人生不能像做菜,把所有的料都准备好了才下锅." 但做大数据挖掘不一样,MapReduce 不同于人生,一定要把准备工作做好了,才能顺利运行后面的步 ...

  4. Hive:用Java代码通过JDBC连接Hiveserver

    写在前面的话,学Hive这么久了,发现目前国内还没有一本完整的介绍Hive的书籍,而且互联网上面的资料很乱,于是我决定写一些关于<Hive的那些事>序列文章,分享给大家.我会在接下来的时间 ...

  5. Java代码通过JDBC连接Hiveserver2

    Java代码通过JDBC连接Hiveserver2 转载 2016年04月26日 16:33:35 344 用Java代码通过JDBC连接Hiveserver2 我们可以通过CLI.Client.We ...

  6. Hive mysql 内连接_Hive-表连接 | 学步园

    Hive只支持等值连接,即ON子句中使用等号连接,不支持非等值连接. Hive内置的数据存储类型,TextFile, SequenceFile, ORC(列式存储) 如果连接语句中有WHERE子句,会 ...

  7. Java代码通过Kerberos连接HDFS

    准备配置文件工作: 1. hdfs-site.xml , core-site.xml 从[集群中下载] 2. hadoop.keytab [创建kerberos访问的用户生成] 3. krb5.con ...

  8. hive 内连接 左外连接 右外连接 满外连接 左半开连接 交叉连接 多表连接 隐式连接

    目录 hive outline hive 内连接 inner join hive 左外连接 left join hive 右外连接 right join hive 满外连接 full join hiv ...

  9. HIVE 中 内连接 外连接 左外连接 右外连接 全外连接 联合操作

    hive的join操作,只支持等值连接 创建customers和orders表,一对多关系 创建customers表 create table customers(id int,name string ...

最新文章

  1. blender动画全面学习教程
  2. mongodb 安装_1、MongoDB 安装
  3. 蓝桥杯省赛最短路径-模板
  4. 怎么用leangoo做需求管理及规划?(产品Backlog、用户故事)
  5. 1-4月份我国软件业务收入15753亿元 同比增长13.1%
  6. 解密蚂蚁金服MISA:37℃的自助语音交互是怎么做到的?
  7. ArrayList 源码阅读记录
  8. leetcode 151. 翻转字符串里的单词 c代码 三种方案
  9. golang 数组 最后一个_Golang 内存管理
  10. idea中java文件红色处理
  11. 快速排序---计数排序
  12. 一个Java对象到底占多大内存?
  13. 神界计算机丢失msvcp120.dll,win8 msvcp120.dll丢失怎样修复?计算机中丢失msvcp120.dll处理办法...
  14. java编译异常有哪些_java编译时异常有哪些?java常见异常有哪些?
  15. Mysql8数据库导到Mysql5数据库,报错Unknown collation: 'utf8mb4_0900_ai_ci'
  16. 黑道圣徒3如何去掉马赛克
  17. 自监督学习经典之作:DINO
  18. Android ToolBar修改返回按钮图标
  19. 安装Kaggle库,常见问题上之目录中没有.kaggle文件夹(附解决办法!)
  20. 短视频源码APP开发——短视频的功能

热门文章

  1. 绝对零门槛,IDEA两步搭建好Java开发环境
  2. 教你如何做出想要的PHPDocker镜像
  3. Netty架构设计与功能特性
  4. 云原生持续交付的模式和实践
  5. 系统最小的服务最小的权限最大的安全。
  6. 【安全牛学习笔记】抓包嗅探
  7. 手机monkey测试BUG重现及解决方法
  8. linux shell之case用法
  9. 怎么理解anchor
  10. mysql时间排序最后一个_如何在MySQL中按日期排序,但最后放置空日期?