【问题标题】:Running multiple hiveQL statements in scala code [duplicate]在scala代码中运行多个hiveQL语句[重复]
【发布时间】:2017-09-06 13:48:11
【问题描述】:

我想在我的 spark 驱动程序代码中执行一组 hiveQL 语句,如下所示

var res = hiveContext.sql("""use testdb;drop table temp;select ...")

当我执行这段代码时,它给了我一个错误提示

Error: missing EOF near testdb

有人能指出我哪里出错了吗?使用上面的方法真的可以执行多个语句吗?

此外,我尝试将所有语句放入文件“test.hql”中,并使用以下代码 sn-p。

sqlContext.sql(scala.io.Source.fromFile("mytest.hql").mkString)    

仍然出现与上述相同的错误。

有什么想法吗?

【问题讨论】:

    标签: apache-spark hive hiveql


    【解决方案1】:

    您可以将所有查询归档并使用此代码执行查询

    queryFile = "path_of_your_file_queries"
    Source.fromFile(queryFile, "utf-8").getLines().foreach(query => sparksql.sql(query))
    

    【讨论】:

      猜你喜欢
      • 2019-06-28
      • 1970-01-01
      • 1970-01-01
      • 2016-05-08
      • 2019-01-20
      • 2022-01-28
      • 1970-01-01
      • 1970-01-01
      • 2019-12-30
      相关资源
      最近更新 更多