我在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。我得到的错误是
请帮帮我!谢谢。
1条答案
按热度按时间5kgi1eie1#
去掉括号
select(...)
. 如果包含圆括号,则select语句将被解释为选择所有选定列中的单个结构列。