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星火

回答

相關問題