0
У меня есть SQL-запрос, который я хочу, чтобы преобразовать в искровым ScalaПреобразование Sql запрос искры
SELECT aid,DId,BM,BY
FROM (SELECT DISTINCT aid,DId,BM,BY,TO FROM SU WHERE cd =2) t
GROUP BY aid,DId,BM,BY HAVING COUNT(*) >1;
SU мой кадр данных. Я сделал это
sqlContext.sql("""
SELECT aid,DId,BM,BY
FROM (SELECT DISTINCT aid,DId,BM,BY,TO FROM SU WHERE cd =2) t
GROUP BY aid,DId,BM,BY HAVING COUNT(*) >1
""")
Вместо того, что мне это нужно в использовании моего dataframe
показать, что вы пробовали до сих пор –
если SU это ваше dataframe, чтобы использовать так, как вы упомянули сначала, вам необходимо зарегистрировать его как временную таблицу SU.registerTempTable ("table_name") и использовать это имя таблицы в своем запросе. –
@RaphaelRoth 'val GP = SU.groupBy (« помощь »,« DId »,« BM »,« BY »). Agg (countDistinct (« помощь »,« DId »,« BM »,« BY »,« TO ") .alias (" count ")> 1) .show'. Был зарегистрирован как временная таблица, но я не хочу использовать SQL-запрос – Anji