從Spark中的SQL查詢創建表（v.1.5.2）

Question

我有一個相當直接的問題，我如何從Spark(1.5.2)的SQL查詢中創建表？

我已經看到，在標準SQL Server 2008，這種解決方式如下：

Select * into new_table from old_table 

是否有任何星火類似的公式，不需要在Dataframe使用.filter()？

Answer 1

首先保存你的數據幀爲 「OLD_TABLE」 表

df.registerTempTable("old_table") 

再次看了你的舊錶爲新的數據框

val newDF=sqlContext.sql("select * from old_table ") 

保存火花sql

newDF.registerTempTable("new_table") 

Answer 2

您可以使用以下方法：

create table "database.table_name" select * from "database.table_name" where "your_condition if any"