从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"