我正在使用SparkSQL。我有下表:
部门:
dep_id | emp_id | age
0 | 0 | 21
0 | 1 | 53
0 | 3 | 42
0 | 5 | 58
1 | 4 | 36
1 | 8 | 48
2 | 2 | 54
2 | 6 | 31
2 | 7 | 30
2 | 9 | 54
但是,我无法在SparkSQL中成功执行以下查询:
SELECT A.dep_id,
A.emp_id,
A.age,
(SELECT MAX(age) FROM department B WHERE A.dep_id = B.dep_id) max_age
FROM department A
ORDER BY 1,2
谁能帮我解决我的问题。
谢谢
您应该声明表alias
:
SELECT A.dep_id, A.emp_id, A.age,
(SELECT MAX(b.age) FROM department B WHERE A.dep_id = B.dep_id) max_age
FROM department A;