当前位置: 首页 > 知识库问答 >
问题:

如何在Spark 1.3的Hive上指示SparkSQL中的数据库

闻人升
2023-03-14
val hc = new HiveContext(sc)
val mySql = "select PRODUCT_CODE, DATA_UNIT from account"
hc.sql("use myDatabase")
val rdd = hc.sql(mySql).rdd
hc.sql("use myDatabase")
Exception in thread "main" java.lang.RuntimeException: [1.1] failure: ``insert'' expected but identifier use found

use myDatabase
^

共有1个答案

南门野
2023-03-14

在以后的Spark版本中支持

https://docs.databricks.com/spark/latest/spark-sql/language-manual/use-database.html

您需要将该语句放在两个单独的spark.sql调用中,如下所示:

spark.sql("use mydb")
spark.sql("select * from mytab_in_mydb").show
 类似资料:
  • 这些查询是:select*from t1 where col1='123'[t1由col1 bucketted]select*from t1 where col2='123'[col2不是bucketting列]我的问题是 > 如何确定在查询执行期间正在进行全表扫描还是正在进行相关的部分表扫描? 我能从DAG或物理计划中得到任何信息吗?我两个都看过,但我看不出有什么不同,就像我在物理计划中看到的那

  • 所以,数据库(MySQL)中有一个包含姓名和照片(blob)的表。在我的网页应用程序的主页上有一个按钮,点击它后-它必须是另一个页面,包含数据库的所有结果。我使用servlet/jsp/、jdbc和MVC模式,我有带有字段名称和照片(字节[])的实体User,我有返回List的DAO类,我想在结果页面上从数据库中检索每个用户照片和照片附近的他的名字。 如何使用 servlet/jsp 执行此操作?

  • 我面临一个问题。 因此,当我尝试使用下面的命令将mongo数据导入到hive时,它给了我一个错误。 注: 使用的工具版本如下: Java JDK 8 Hadoop:2.8.4 蜂巢:2.3.3 MongoDB:4.2 jar版本如下,已移到HADOOP_HOME/lib和HIVE_HOME/lib: mongo-hadoop-core-2.0.2。罐子 mongo-hadoop-hive-2.0.

  • 我有一个,如下所示,它可以从CMS/Database中提取数据。  反应代码: Z行打印以下内容: 问题说明:在上面的代码中,中的div没有打印任何内容,尽管我能够在中显示所有内容。

  • 问题内容: 使用 在现有数据库中显示数据的最佳方法是什么? 答案中没有包含全部解释,因此,我添加了此问与答样式,以便可以将其链接到注释中。 问题答案: 假设你具有一个如下所示的Firestore数据库结构: 看起来也像这样的模型类: 包含的文件也如下所示: 要显示所有产品名称,请按照以下步骤操作。 首先,你需要RecyclerView在你的活动中找到并进行如下设置LinearLayoutManag

  • JBoss EAP 6中XA数据源的连接属性在XA属性选项卡中配置,例如使用ServerName、DatabaseName和PortNumber属性。如何指定数据源要连接到的SQL Server数据库实例名称? 在jtds中,我使用模式:jdbc:jtds:sqlserver://@ServerName/@DatabaseName;实例=@InstanceName