首页 > 数据库 >Spark SQL

Spark SQL

时间:2023-08-13 09:22:34浏览次数:28  
标签:Shark CLI DataFrame Hive SQL Spark

Spark SQL

1.1Spark SQL简介

Spark SQL是一个用来处理结构化数据的Spark 组件。它可被视为一个分 布式的SQL查询引擎,并且提供了一个叫作DataFrame的可编程抽象数据模型。Spark SQL的前身是Shark,由于Shark需要依赖于Hive而制约了Spark 各个组件的相互集成,因此Spark团队提出了Spark SQL项目。

Spark SQL提供的最核心的编程抽象是DataFrame, DataFrame是一个分布式的Row对象的数据集合,其本身实现了RDD的绝大多数功能。Spark SQL通常从外部数据源加载数据为DataFrame,然后通过DataFrame上丰富的API进行查询、转换,最后可将结果进行展现或存储为各种外部数据形式。

image-20200427075632768

1.2Spark SQL CLI配置

Spark SQL可以兼容Hive以便Spark SQL支持Hive表访问、UDF ( 用户自定义函数)以及Hive查询语言( HiveQLHQL )。从Spark 1.1 开始,Spark 增加了Spark SQL CLI和ThritServer,使得Hive用户还有用惯了命令行的RDBMS数据库管理员较容易上手。

若要使用Spark SQL CLI的方式访问操作Hive表数据,需要对Spark SQL进行如下所示的环境配置( Spark集群已搭建好),将Spark SQL连接到一一个部署好的Hive.上。当然,即使没有部署好Hive, Spark SQL也可以运行,但是Spark SQL会在当前的工作目录中创建出自己的Hive元数据库.称为metastore_ db。 下面介绍配置Spark SQL使用的Hive环境。

标签:Shark,CLI,DataFrame,Hive,SQL,Spark
From: https://www.cnblogs.com/simpleness/p/17626149.html

相关文章

  • mysql在索引定义中直接使用条件语句
    原始数据库表如下:CREATETABLE`events`(`id`int(11)unsignedNOTNULLAUTO_INCREMENT,`status`enum('on','off')COLLATEutf8_unicode_ciNOTNULLCOMMENT'开关状态',`type`enum('gas_fee_free')COLLATEutf8_unicode_ciNOTNULL......
  • mysql8默认caching_sha2_password身份验证
    发生这个问题的原因是在mysql8.0以后,caching_sha2_password是默认的身份验证插件,而不是以往的mysql_native_password。在MySQLCommandLine工具下修改mysql的默认身份验证插件即可。Theserverrequestedauthenticationmethodunknowntotheclient[caching_sha2_passw......
  • SQL学习
    前言SQL,全称为StructuredQueryLanguage(结构化查询语言)数据库,一般就是指的 Relationaldatabase(关系型数据库),是用来存储大量数据的一种软件SQL是用来操作数据库里的数据,具体来说SQL可以做数据查询,数据更新,写入数据等等。......
  • MSSQL 锁机制
    铺垫知识在我开始解释SQLServer锁定体系结构之前,让我们花点时间来描述ACID(原子性,一致性,隔离性和持久性)是什么。ACID是指数据库管理系统(DBMS)在写入或更新资料的过程中,为保证事务(transaction)是正确可靠的,所必须具备的四个特性:原子性(atomicity,或称不可分割性)、一致性(consistency)、隔......
  • sqlite的安装和使用
    1.安装到[官网]:https://www.sqlite.org/download.html去下载对应系统版本,这里以win为例需要下载两个文件下载解压后放入同一个文件夹中将路径加入到系统变量Path中打开命令行,验证是否安装成功:输入sqlite3即成功2.使用SQLite是一个自包含的、零配置的SQL数据库引......
  • SQL语法(待完善)
    SQLStructuredQueryLanguage结构化查询语言定义了操作关系性数据库的规则存在一定的版本之间的差异1.1SQL概述SQL语句以单行,多行书写,以分号结尾不区分大小写关键字建议大写--单行注释#注释内容/*多行注释*/结构化查询语言SQL是用于访问和处理数......
  • Spark提交程序到Yarn任务状态一直为Accepted
    正在学习《Spark快速大数据分析》第七章-在集群上运行Spark,写了一个单词数量统计的Spark程序提及到Yarn,但是状态一直是Accepted,等待运行。1、排查了Yarn资源调度器配置,配置的是公平配置,确认无问题<property> <name>yarn.scheduler.fair.allocation.file</name> <value>/opt/ha......
  • SpringBatch读取mysql数据
    1.在本地数据库创建user表建表语句:createtable`user`(`id`bigintnotnullauto_incrementcomment'主键',`name`varchar(32)defaultnullcomment'用户名',`age`intdefaultnullcomment'年龄',primarykey(id))engine=innodbde......
  • pyspark小案例
    ##py_pyspark_demo.py#py_learn##CreatedbyZ.Steveon2023/8/1215:33.##统计文件中各个单词出现的次数#1.导入库frompysparkimportSparkConf,SparkContext#2.创建SparkConf对象和SparkContext对象conf=SparkConf().setMaster("local......
  • 【Labview与SQL Server互联(labview可以引用数据库)】
    (Labview与SQLServer互联(labview可以引用数据库))一、工具的下载点击:LabviewSQL工具包进行工具包的下载1.1安装下载完成后,进入C盘,找到如图所示的文件夹,找到需要安装的labview版本文件夹,双击进入找到uesr.lib文件夹,双击进入将刚刚下载的工具包解压,直接复制进user.lib文......