Агрегация с мин в писпарке

Question

Я пытаюсь объединить даты дат на минимальное значение.Я пытался использовать groupby (), но он выдает ошибку.

   history= history.selectExpr('aaa'\
        , 'bbb'\
        , 'ccc'\
        , 'date')

        history=history.groupBy()('aaa','bbb','ccc',min('date'))

Я пытался сначала

       history= history.selectExpr('aaa'\
            , 'bbb'\
            , 'ccc'\
            , min('date'))

, но он не работал ни

Спасибо:)

Answer 1

Вы можете просто сделать это:

from pyspark.sql import functions as F
history.groupBy("AAA","BBB","CCC").agg(F.min("date"))