我有一张临时table spark_tmp_view
与 DATE_KEY
列。我正在尝试创建一个配置单元表(不将临时表写入Parquet地板位置)。我想跑的是 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应用程序中进行搜索,以及如何在搜索后插入数据。有人能帮忙吗?非常感谢。
1条答案
按热度按时间aor9mmx11#
PARTITIONED BY
是正在创建的表定义的一部分,因此它应该在...AS SELECT...
,请参见spark sql语法。