首页 > 数据库 >SparkSQL 操作Hive

SparkSQL 操作Hive

时间:2024-01-15 12:11:08浏览次数:37  
标签:xml bin site Hive SparkSQL 操作 spark Spark usr

Spark中本身内置了Hive,但一般用于测试,生产环境中需要连接外置的Hive

1.将Hive的配置文件hive-site.xml拷贝到Spark的配置目录下

cp /usr/hive/apache-hive-3.1.3-bin/conf/hive-site.xml /usr/spark/spark-3.5.0-bin-hadoop3/conf

2.将Mysql JDBC驱动放置在Spark的jars目录下

1.下载Mysql JDBC驱动

地址1(Mysql官方托管):https://downloads.mysql.com/archives/c-j/
image

地址2(Maven中央仓库托管): https://mvnrepository.com/artifact/com.mysql/mysql-connector-j
image

2.拷贝驱动

cp /home/mysql-connector-j-8.0.33.jar /usr/spark/spark-3.5.0-bin-hadoop3/jars

3.将Hadoop的core-site.xmlhdfs-site.xml拷贝到Spark配置目录下

cp /usr/hadoop/hadoop-3.3.6/etc/hadoop/{hdfs-site.xml,core-site.xml} /usr/spark/spark-3.5.0-bin-hadoop3/conf

4.重启Spark-shell

/usr/spark/spark-3.5.0-bin-hadoop3/bin/spark-shell

标签:xml,bin,site,Hive,SparkSQL,操作,spark,Spark,usr
From: https://www.cnblogs.com/fanqisoft/p/17965106

相关文章

  • 操作滚动条小结:scrollIntoView/animate等方法的来龙去脉
    操作滚动条可以通过锚点跳转,JS操作滚动条,与scrollIntoView等方法。对此,我来考古一下。锚点跳转滚动滚动条网页中的锚点跳转是HTML早期功能之一,锚点(anchor)跳转是1991年发布的HTML标准的一部分,这是超文本链接的基本特性。锚点跳转通过使用<a>标签的href属性来创建指向页面内部某......
  • LCD 硬件操作原理
    1、LCD显示原理  FrameBuffer即显存   SMT32与液晶控制芯片通过8080接口通讯,而液晶控制芯片包含显存、LCD控制器、LCD屏幕,液晶控制芯片常见有RA8875、ILI9341等芯片 嵌入式Linux则使用TFTRGB接口,内存和LCD控制器集成在Soc里面,外部接一个LCD屏幕。......
  • 复选框的操作,看这一篇就够啦~~
    平常在工作中对于复选框的操作算频繁的了。尽管在网上已经有很多这方面的文章了,但是感觉总结的不够详细。下面是本人对于操作复选框进行的一些总结。下面的方法大多是基于jquery的,所以要记得引用jquery哦~~用原生js的地方做了说明,大家各取所需吧。HMTL代码如下:1<!DOCTYPEh......
  • SparkSQL 自定义聚合函数[强类型] & DSL
    本文的前提条件:SparkSQLinJava参考地址:UserDefinedAggregateFunctions(UDAFs)1.声明列实体类packagecn.coreqi.entity;importjava.io.Serializable;publicclassUserimplementsSerializable{privateStringusername;privateLongage;publi......
  • C#与C++代码的互操作方式
    title:C#与C++代码的互操作方式date:2024-01-10categories:编程tags:-C#-.NET-C++-COM-平台调用大致介绍在写C#程序时经常有与本地代码(C/C++)代码交互的需求。微软提供了许多种方式供我们选择,最常用的有以下三种(A->B指A可以引用B):flowchartLRA--P/Invoke......
  • C语言文件操作
    写文件-输出相应字符/字符串到相应的文本文件#define_CRT_SECURE_NO_WARNINGS1#include<stdio.h>#include<errno.h>#include<string.h>intmain()//输入字符到TEST.txt中{ FILE*pfwrite=fopen("TEST.txt","w"); if(pfwrite==NULL)//打开失败情况 { prin......
  • SparkSQL 自定义聚合函数[强类型]
    本文的前提条件:SparkSQLinJava参考地址:UserDefinedAggregateFunctions(UDAFs)1.自定义实体类packagecn.coreqi.entity;importjava.io.Serializable;publicclassAverageimplementsSerializable{privatelongtotal;privatelongcount;publi......
  • SparkSQL 自定义聚合函数[弱类型]
    本文的前提条件:SparkSQLinJava代码如下1.自定义聚合函数packagecn.coreqi.udaf;importorg.apache.spark.sql.Row;importorg.apache.spark.sql.expressions.MutableAggregationBuffer;importorg.apache.spark.sql.expressions.UserDefinedAggregateFunction;import......
  • SparkSQL 自定义函数
    本文的前提条件:SparkSQLinJava参考地址:ScalarUserDefinedFunctions(UDFs)完整代码packagecn.coreqi;importstaticorg.apache.spark.sql.functions.udf;importorg.apache.spark.SparkConf;importorg.apache.spark.sql.*;importorg.apache.spark.sql.expres......
  • SparkSQL in Java
    参考地址:StartingPoint:SparkSession1.新建Maven项目,POM引入依赖<dependencies><dependency><groupId>org.apache.spark</groupId><artifactId>spark-core_2.13</artifactId><version&......