如何使用 PySpark 查询字段中的最大值/最大值

Question

以下数据框将产生 0 到 3 的值。

df = DeltaTable.forPath(spark, '/mnt/lake/BASE/SQLClassification/cdcTest/dbo/cdcmergetest/1').history().select(col("version"))

有人可以告诉我如何修改数据框，使其只提供最大值，即 3 吗？

我试过了

df.select("*").max("version")

和

df.max("version")

但是没有运气

有什么想法吗？

Answer 1

df.select(max('version')).collect()