前台会传来一条select语句，使用hivecontext.sql去执行。但用户写表的时候，可能不会指定数据库名，所以是想先执行一下 use dbName，再执行查询语句，保证能够找到这站表。那么在Scala程序中如何去实现呢？？
使用Spark 的 hivecontext.sql查询，如何批量执行语句
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
1条回答 默认 最新
关注不知道你这个问题是否已经解决, 如果还没有解决的话:- 这篇文章讲的很详细，请看：hive on spark 执行sql报错
如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 写成博客, 将相关链接放在评论区, 以帮助更多的人 ^-^解决 无用评论 打赏举报 分享
- 2022-12-15 15:54
Spark 读取 Hive 数据报错 NoSuchMethodError : org.apache.spark.sql.catalyst.catalog.SessionCatalog
hive
spark
大数据
回答 1 已采纳 22/12/15 15:32:44 INFO SparkContext: Invoking stop() from shutdown hook集群资源不足，且动态资源分配申请的executors、内存 - 2019-08-09 21:16 Error while instantiating 'org.apache.spark.sql.hive.HiveSessionState'
eclipse
intellij-idea
java
java-ee
scala
回答 3 已采纳 这个问题我已经解决，我发现是仔细看了一下，后面的错误是Exception in thread "main"java.lang.UnsatisfiedLinkError，我本地的hadoop版本是2.7
- 2022-05-19 17:16回答 1 已采纳 SELECT SUBSTR(NAME,1,INSTR(NAME,'(')-1),COUNT(1)FROM (SELECT '顶层(共20层)' NAME UNION ALLSELECT '顶层(共21
- 2021-08-16 21:21Oak-Komorebi的博客 SparkSQL是Spark⽣态体系中的构建在SparkCore基础之上的⼀个基于SQL的计算模块。 SparkSQL的前身不叫SparkSQL，⽽叫Shark，最开始的时候底层代码优化，sql的解析、执⾏引擎等等完全基于 Hive，总是Shark的执⾏速度要...
- 2022-02-09 14:38 在使用Spark连接数据库时发生Caused by: java.sql.SQLException: Out of range value for column 'age' : value age
java
spark
sql
回答 1 已采纳 http://cn.voidcc.com/question/p-ozcajljc-dh.html，看下这个
- 2023-01-17 22:05回答 2 已采纳 这是一个连接Doris服务器失败的错误，具体原因可能是Doris服务器无法连接或网络故障导致的。
- 2022-01-18 20:31回答 3 已采纳 spark sql中可以使用except来获得两组数据的交集 SELECT * FROM student_1 EXCEPT SELECT * FROM student_2; 你如果是某一行中的某
- 2021-12-25 18:16大数据老司机的博客 文章目录一、Spark SQL概述二、SparkSQL版本1）SparkSQL的演变之路2）shark与SparkSQL对比3）SparkSession三、RDD、DataFrames和DataSet1）三者关联关系1）RDD1、核心概念2、RDD简单操作3、RDD API1）Transformation...
- 2017-06-06 08:21回答 1 已采纳 在目前Hive 1.2的JDBC版本里面，使用它会报错：`java.sql.SQLException: Method not supported at org.apache.hive.jdbc.Hiv
- 2021-11-24 10:01回答 1 已采纳 你把它复制到记事本发给我
- 2022-12-26 21:08回答 2 已采纳 Spark SQL 的执行顺序通常分为以下几步：解析 SQL 语句：Spark SQL 会先将 SQL 语句解析成内部的表达式树，以便对其进行更好的优化。优化表达式树：在解析后，Spark SQL 会
- 2023-09-09 19:03让线程再跑一会的博客 Spark SQL、DataFrame的创建与保存、DataFrame的两种操作：DSL语句和SQL语句。
- 2022-03-27 14:34回答 2 已采纳 把情景一改成这样试试spark.sql(""" INSERT INTO hive_test_one.djia_table(date, open, high, low, close, volume,
- 2019-01-14 09:48零零天的博客 Spark调优—上篇 更好的序列化实现 Spark用到序列化的地方 1）Shuffle时需要将对象写入到外部的临时文件。 2）每个Partition中的数据要发送到worker上，spark先把RDD包装成task对象，将task通过 网络发给worker。 3...
- 2021-05-29 12:37Robin_Liew的博客 Spark SQL提供了一种特殊的RDD，叫做SchemaRDD。 SchemaRDD是存放Row对象的RDD，每个Row对象代表一行记录。 SchemaRDD支持RDD上所没有的一些新操作，比如运行SQL查询。 SchemaRDD可以从外部数据源创建，也可以从查询...
- 没有解决我的问题, 去提问
悬赏问题
- ¥50 有数据，怎么建立模型求影响全要素生产率的因素
- ¥50 有数据，怎么用matlab求全要素生产率
- ¥15 TI的insta-spin例程
- ¥15 完成下列问题完成下列问题
- ¥15 C#算法问题, 不知道怎么处理这个数据的转换
- ¥15 YoloV5 第三方库的版本对照问题
- ¥15 请完成下列相关问题！
- ¥15 drone 推送镜像时候 purge: true 推送完毕后没有删除对应的镜像,手动拷贝到服务器执行结果正确在样才能让指令自动执行成功删除对应镜像，如何解决？
- ¥15 求daily translation（DT）偏差订正方法的代码
- ¥15 js调用html页面需要隐藏某个按钮