分析能量消耗
在这一步中,我们将使用 min
和 max
函数来分析飞行员在以往比赛中的能量消耗模式。
- 创建一个名为
energy_consumption
的新表来存储能量消耗数据:
CREATE TABLE energy_consumption (
pilot_id INT,
race_id INT,
energy_consumed DOUBLE
)
ROW FORMAT DELIMITED
FIELDS TERMINATED BY ','
STORED AS TEXTFILE;
- 将
race_data/energy_consumption.csv
文件中的能量消耗数据加载到 energy_consumption
表中:
LOAD DATA INPATH '/home/hadoop/race_data/energy_consumption.csv' INTO TABLE energy_consumption;
- 查找每位飞行员在所有比赛中的最小和最大能量消耗:
SELECT pilot_id, min(energy_consumed) AS min_energy_consumed, max(energy_consumed) AS max_energy_consumed
FROM energy_consumption
GROUP BY pilot_id;
- 计算每位飞行员在所有比赛中的平均能量消耗:
SELECT pilot_id, avg(energy_consumed) AS avg_energy_consumed
FROM energy_consumption
GROUP BY pilot_id;
这些查询将帮助你了解飞行员的能量消耗模式,从而影响新赛道上能量补给站的布局以及节能路段的设计。