Где предложение с функцией агрегации на SparkSQL Thriftserver, связанном с beeline

Question

Я подключен к Spark Thrift (Spark SQL версии 2.3.1 и Hive JDBC 1.2.1.spark2) из ​​Beeline и хочу выполнить запрос ниже.

Выбрать * из таблицы1, где age> avg (age));

Но я получаю сообщение об ошибке "UnsupportedOpertionException"

Просим вас помочь ..

Answer 1

Попробуйте ниже,

Подзапросы поддержки Hive с in/exists/notin/notexists

with avg_age as
(select avg(age) as age1 from table1),
select * from table1 t1, avg_age t2 where t1.age>t2.age.

Или используйте объединения.

select * from table1 t1 inner join
(select avg(age) as age1 from table1) t2
on t1.<UniqCol>=t2.<UniqCol> where t1.age>t2.age.