如何使用sql在spark中用select从另一个表中创建一个表

unftdfkk  于 2021-07-13  发布在  Spark
关注(0)|答案(1)|浏览(361)

我在hdfs中保存了一个名为 usedcars . 我想根据这个表上select语句的输出创建另一个表,如下所示

%spark.sql
CREATE TABLE cleanusedcars
AS (
select (maker, model, mileage, manufacture_year, engine_displacement, engine_power, transmission, door_count, seat_count, fuel_type, date_created, date_last_seen, price_eur)
from usedcars
where maker is not null and model is not null and price_eur <= 2000000 and price_eur >= 3000 and manufacture_year <= 2017 and manufacture_year >= 2000
)

我正在齐柏林飞艇笔记本中使用sparksql。我得到的错误是

请帮帮我!谢谢。

5kgi1eie

5kgi1eie1#

去掉括号 select(...) . 如果包含圆括号,则select语句将被解释为选择所有选定列中的单个结构列。

相关问题