Как получить значение MIN столбца таблицы Apache Kudu? - PullRequest
0 голосов
/ 27 апреля 2018

Я использую 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 не определенная ошибка.

1 Ответ

0 голосов
/ 13 октября 2018

Из вашего примера похоже, что вы уже используете Impala. Вы можете использовать функцию MIN в Impala SQL, чтобы получить минимальное значение. E.g.:

SELECT MIN(amount) FROM mydb.mytable
...