Я использую PySpark для подключения к моей базе данных Kudu. Я хочу получить минимальное значение в столбце с набором предикатов. Не могу найти вариант в API
client = kudu.connect(host="myhost", port=1234)
table = client.table("impala::mydb.mytable")
scanner = table.scanner()
scanner.add_predicates([table['col1'] == 'test'])
scanner.set_project_column_names(['amount'])
myList = scanner.open().read_all_tuples()
Выше приведен список, но я не уверен, как указать, что я хочу значение MIN для столбца суммы.
Пытались
scanner.set_project_column_names([MIN('amount')])
но это приводит к MIN не определенная ошибка.