sparkSQL操作hiveSQL

   <dependency><groupId>org.apache.spark</groupId><artifactId>spark-hive_2.11</artifactId><version>2.3.3</version></dependency>
import org.apache.spark.sql.SparkSession//todo:利用sparksql操作hivesql
object HiveSupport {def main(args: Array[String]): Unit = {//1、构建SparkSession对象val spark: SparkSession = SparkSession.builder().appName("HiveSupport").master("local[2]").enableHiveSupport() //开启对hive的支持.getOrCreate()//2、直接使用sparkSession去操作hivesql语句//2.1 创建一张hive表spark.sql("create table people(id string,name string,age int) row format delimited fields terminated by ','")//2.2 加载数据到hive表中spark.sql("load data local inpath './data/kaikeba.txt' into table people ")//2.3 查询spark.sql("select * from people").show()spark.stop()}
}

sparkSQL操作hiveSQL相关推荐

  1. SparkSQL操作Hive

    title: SparkSQL操作Hive date: 2020-05-12 16:12:55 tags: Spark Apache Hive 是 Hadoop 上的 SQL 引擎,Spark SQL ...

  2. idea sparksql操作hive遇到的坑CoarseGrainedSchedulerBackend$DriverEndpoint: Asked to remove non-existent ex

    sparksql操作hive遇到的坑 第一次写sparksql项目想用sparksql操作hive查询数据就找到了百度代码做参考[idea工具开发] 代码如下: import org.apache.s ...

  3. python读取oracle数据到hvie parquet_关于sparksql操作hive,读取本地csv文件并以parquet的形式装入hive中...

    说明:spark版本:2.2.0 hive版本:1.2.1 需求: 有本地csv格式的一个文件,格式为${当天日期}visit.txt,例如20180707visit.txt,现在需要将其通过spar ...

  4. sparksql 操作hive_Spark SQL 物化视图原理与实践

    导言 物化视图作为一种预计算的优化方式,广泛应用于传统数据库中,如Oracle,MSSQL Server等.随着大数据技术的普及,各类数仓及查询引擎在业务中扮演着越来越重要的数据分析角色,而物化视图作 ...

  5. sparksql 操作hive_三十六、图解SparkSQL运行原理

    SparkSQL运行原理 1.SparkSQL的运行简化流程 进行DataFrame|Dataset|SQL编程; Spark会将编写的代码转换并生成一个逻辑计划; Spark会将此逻辑计算转换生成一 ...

  6. SparkSQL操作Hive Table

    Spark SQL支持对Hive的读写操作.然而因为Hive有很多依赖包,所以这些依赖包没有包含在默认的Spark包里面.如果Hive依赖的包能在classpath找到,Spark将会自动加载它们.需 ...

  7. Spark之 使用SparkSql操作mysql和DataFrame的Scala实现

    通过读取文件转换成DataFrame数据写入到mysql中 package com.zy.sparksqlimport java.util.Propertiesimport org.apache.sp ...

  8. SparkHiveSQL中Join操作的谓词下推?

    前言: SparkSQL和HiveSQL的Join操作中也有谓词下推?今天就通过大神的文章来了解下.同样,如有冒犯,请联系. 正文 上文简要介绍了Join在大数据领域中的使用背景以及常用的几种算法-b ...

  9. SparkSQL核心编程

    目录 基本介绍 DataFrame 创建 DataFrame DataSet 创建 DataSet RDD 转换为 DataSet DataSet 转换为 RDD DataFrame 和 DataSe ...

最新文章

  1. mass Framework pagination插件
  2. bash脚本编程之一 变量、变量类型等
  3. 华为鸿蒙不再孤单mmes,华为Watch GT2新色图赏 简约时尚设计新增100种运动模式
  4. 41状态模式(State Pattern)
  5. 空间注意力机制sam_Attention注意力机制介绍
  6. java封装对象数组_java解析JSON对象和封装对象的示例
  7. linux常用软件推荐
  8. ArcGIS的基本使用
  9. matlab表示开方,在MATLAB内置功能中,‘sqrt(a)’表示() 答案:对a开方
  10. MySQL(管理员常用命令)
  11. 一篇文章带你了解系统流程图和业务流程图的区别
  12. 西安大唐提车游记——感受古都容颜
  13. 新《劳动法》能要来“双薪”?
  14. openlayers 设置边界线外圈遮罩
  15. 个人信贷评估模型研究
  16. win7记事本如何转换html,记事本格式_win7记事本怎么改格式
  17. 简单易懂之什么是重排和重绘?
  18. Android面试题集锦
  19. 超好玩的mac模拟经营游戏:巨型水族馆中文版
  20. 读书笔记之 大型网站技术架构(核心原理与案例分析)

热门文章

  1. AES算法重点详解和实现
  2. table表头固定4种方法_在常见的3种工资条场景中,教你4种批量打印工资条的方法...
  3. oracle定义转储目录,Oracle 12.1新特性:在线rename或relocate数据文件
  4. 觅凤c语言教程,C语言程序设计教程 第1章.ppt
  5. mysql开窗函数over_oracle分析函数技术详解(配上开窗函数over())
  6. php 如何守护进程_PHP 如何实现守护进程
  7. redis 如何 mysql_Redis 如何保持和 MySQL 数据一致
  8. docker安装gitlab_docker 安装部署gitlab
  9. python可视化分析网易云音乐评论_网易云音乐热门评论api分析
  10. 快能通小学生计算机的游戏,亲子小游戏,帮助孩子更快学会交通安全知识