Apache的SQL星火

删除临时表我有registertemptable在Apache Spark使用下面Zeppelin：Apache的SQL星火

val hvacText = sc.textFile("...") 

case class Hvac(date: String, time: String, targettemp: Integer, actualtemp: Integer, buildingID: String) 

val hvac = hvacText.map(s => s.split(",")).filter(s => s(0) != "Date").map(
    s => Hvac(s(0), 
      s(1), 
      s(2).toInt, 
      s(3).toInt, 
      s(6))).toDF() 

hvac.registerTempTable("hvac")

我已经与我的这个临时表的查询完成后，我怎么去除呢？

我检查了所有的文档，似乎我无处可去。

任何指导？

来源

2015-09-03 Softwaremaker

星火2.x的

对于临时性的观点，你可以使用Catalog.dropTempView：

spark.catalog.dropTempView("df")

对于全局的观点，你可以使用Catalog.dropGlobalTempView：

spark.catalog.dropGlobalTempView("df")

两种方法都安全地调用如果视图不存在，并且自Spark 2.1以来，返回布尔值，指示操作是否成功。

星火1.x的

您可以使用SQLContext.dropTempTable：

scala.util.Try(sqlContext.dropTempTable("df"))

它可以在2.0星火仍然可以使用，但委托加工Catalog.dropTempView，是安全的，如果表中不使用存在。

来源

2015-09-03 15:24:01 zero323

如果你想删除你的临时表在齐柏林，尝试像这样。

sqlc.dropTempTable("hvac")

或

%sql DROP VIEW hvac

，你可以得到你火花火花API文档（http://spark.apache.org/docs/latest/api/scala/index.html#org.apache.spark.package）

来源

2015-09-03 15:33:48

sqlc.dropTempTable（ “HVAC”）的工作原理。后者没有。非常感谢你！ – Softwaremaker

在新的版本（2.0和最新的）所需要的信息。一个应该使用：createOrReplaceTempView代替registerTempTable（depricated）和解除分配相应的方法是：dropTempView

spark.catalog.dropTempView("temp_view_name") //drops the table

来源

2016-12-29 06:22:11 desaiankitb

Apache的SQL星火

回答

相关问题