Hive 基于 Spark 临时表创建分区表

Question

我有一个带有 DATE_KEY 列的 Spark 临时表 spark_tmp_view。我正在尝试创建一个 Hive 表（没有将临时表写入镶木地板位置。我尝试运行的是 spark.sql("CREATE EXTERNAL TABLE IF NOT EXISTS mydb.result AS SELECT * FROM spark_tmp_view PARTITIONED BY(DATE_KEY DATE)")

我得到的错误是mismatched input 'BY' expecting <EOF> 我试图搜索但仍然无法弄清楚如何从 Spark 应用程序中进行搜索，以及之后如何插入数据。有人可以帮忙吗？非常感谢。

Answer 1

PARTITIONED BY 是正在创建的表定义的一部分，因此它应该在...AS SELECT... 之前，请参阅Spark SQL syntax。